| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.Kafka.Producer
- produce :: Handle -> ProduceRequest -> Kafka ProduceResponse
- produceRequest :: RequiredAcks -> Timeout -> [(TopicAndPartition, MessageSet)] -> ProduceRequest
- produceMessages :: [TopicAndMessage] -> Kafka [ProduceResponse]
- groupMessagesToSet :: [TopicAndMessage] -> MessageSet
- partitionAndCollate :: [TopicAndMessage] -> Kafka (Map Leader (Map TopicAndPartition [TopicAndMessage]))
- send :: Leader -> [(TopicAndPartition, MessageSet)] -> Kafka ProduceResponse
- brokerPartitionInfo :: TopicName -> Kafka [PartitionAndLeader]
- findMetadataOrElse :: [TopicName] -> Getting (Maybe a) KafkaClient (Maybe a) -> KafkaClientError -> Kafka a
- getPartition :: [PartitionAndLeader] -> Kafka (Maybe PartitionAndLeader)
- defaultMessageCrc :: Crc
- defaultMessageMagicByte :: MagicByte
- defaultMessageKey :: Key
- defaultMessageAttributes :: Attributes
- makeMessage :: ByteString -> Message
Producing
produce :: Handle -> ProduceRequest -> Kafka ProduceResponse Source
Execute a produce request and get the raw preduce response.
produceRequest :: RequiredAcks -> Timeout -> [(TopicAndPartition, MessageSet)] -> ProduceRequest Source
Construct a produce request with explicit arguments.
produceMessages :: [TopicAndMessage] -> Kafka [ProduceResponse] Source
Send messages to partition calculated by partitionAndCollate.
groupMessagesToSet :: [TopicAndMessage] -> MessageSet Source
Create a protocol message set from a list of messages.
partitionAndCollate :: [TopicAndMessage] -> Kafka (Map Leader (Map TopicAndPartition [TopicAndMessage])) Source
Group messages together with the leader they should be sent to.
send :: Leader -> [(TopicAndPartition, MessageSet)] -> Kafka ProduceResponse Source
Execute a produce request using the values in the state.
brokerPartitionInfo :: TopicName -> Kafka [PartitionAndLeader] Source
Find a leader and partition for the topic.
findMetadataOrElse :: [TopicName] -> Getting (Maybe a) KafkaClient (Maybe a) -> KafkaClientError -> Kafka a Source
Messages
defaultMessageCrc :: Crc Source
Default: 1
defaultMessageMagicByte :: MagicByte Source
Default: 0
defaultMessageKey :: Key Source
Default: Nothing
defaultMessageAttributes :: Attributes Source
Default: 0
makeMessage :: ByteString -> Message Source
Construct a message from a string of bytes using default attributes.