Network.Kafka.Producer

Producing

produce :: Kafka m => Handle -> ProduceRequest -> m ProduceResponse

Execute a produce request and get the raw produce response.

produceRequest :: RequiredAcks -> Timeout -> [(TopicAndPartition, MessageSet)] -> ProduceRequest

Construct a produce request with explicit arguments.

produceMessages :: Kafka m => [TopicAndMessage] -> m [ProduceResponse]

Send messages to partition calculated by partitionAndCollate.

produceCompressedMessages :: Kafka m => CompressionCodec -> [TopicAndMessage] -> m [ProduceResponse]

Send compressed messages to partition calculated by partitionAndCollate.

prod :: Kafka m => ([TopicAndMessage] -> MessageSet) -> [TopicAndMessage] -> m [ProduceResponse]

groupMessagesToSet :: CompressionCodec -> [TopicAndMessage] -> MessageSet

Create a protocol message set from a list of messages.

partitionAndCollate :: Kafka m => [TopicAndMessage] -> m (Map Leader (Map TopicAndPartition [TopicAndMessage]))

Group messages together with the leader they should be sent to.

getPartitionByKey :: ByteString -> Set PartitionAndLeader -> Maybe PartitionAndLeader

Compute the partition for a record. This matches the way the official | clients compute the partition.

send :: Kafka m => Leader -> [(TopicAndPartition, MessageSet)] -> m ProduceResponse

Execute a produce request using the values in the state.

getRandPartition :: Kafka m => Set PartitionAndLeader -> m (Maybe PartitionAndLeader)

Messages

defaultMessageCrc :: Crc

Default: 1

defaultMessageMagicByte :: MagicByte

Default: 0

defaultMessageKey :: Key

Default: Nothing

defaultMessageAttributes :: Attributes

Default: 0

makeMessage :: ByteString -> Message

Construct a message from a string of bytes using default attributes.

makeKeyedMessage :: ByteString -> ByteString -> Message

Construct a message from a string of bytes using default attributes.