Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- data KafkaProducer = KafkaProducer {
- kpKafkaPtr :: !Kafka
- kpKafkaConf :: !KafkaConf
- kpTopicConf :: !TopicConf
- data ProducerRecord = ProducerRecord {}
- data ProducePartition
- data DeliveryReport
- newtype ImmediateError = ImmediateError KafkaError
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 |
Instances
newtype ImmediateError Source #
Data type representing an error that is caused by pre-flight conditions not being met
Instances
Eq ImmediateError Source # | |
Defined in Kafka.Producer.Types (==) :: ImmediateError -> ImmediateError -> Bool # (/=) :: ImmediateError -> ImmediateError -> Bool # | |
Show ImmediateError Source # | |
Defined in Kafka.Producer.Types showsPrec :: Int -> ImmediateError -> ShowS # show :: ImmediateError -> String # showList :: [ImmediateError] -> ShowS # |