Safe Haskell | None |
---|---|
Language | Haskell2010 |
- data KafkaProducer = KafkaProducer {
- kpKafkaPtr :: RdKafkaTPtr
- kpKafkaConf :: RdKafkaConfTPtr
- kpTopicConf :: RdKafkaTopicConfTPtr
- data ProducerRecord = ProducerRecord {}
- data ProducePartition
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)