Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- data KafkaProducer = KafkaProducer {
- kpKafkaPtr :: !Kafka
- kpKafkaConf :: !KafkaConf
- kpTopicConf :: !TopicConf
- data ProducerRecord = ProducerRecord {}
- data ProducePartition
- data DeliveryReport
Documentation
data KafkaProducer Source #
Main pointer to Kafka object, which contains our brokers
KafkaProducer | |
|
data ProducerRecord Source #
Represents messages to be enqueued onto a Kafka broker (i.e. used for a producer)
ProducerRecord | |
|
Instances
data ProducePartition Source #
Instances
data DeliveryReport Source #
DeliverySuccess ProducerRecord Offset | |
DeliveryFailure ProducerRecord KafkaError | |
NoMessageError KafkaError |