Safe Haskell | None |
---|---|
Language | Haskell2010 |
Module holding producer types.
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 #
The main type for Kafka message production, used e.g. to send messages.
Its constructor is intentionally not exposed, instead, one should used newProducer
to acquire such a value.
KafkaProducer | |
|
data ProducerRecord Source #
Represents messages to be enqueued onto a Kafka broker (i.e. used for a producer)
ProducerRecord | |
|
Instances
data ProducePartition Source #
SpecifiedPartition !Int | The partition number of the topic |
UnassignedPartition | Let the Kafka broker decide the partition |
Instances
data DeliveryReport Source #
The result of sending a message to the broker, useful for callbacks
DeliverySuccess ProducerRecord Offset | The message was successfully sent at this offset |
DeliveryFailure ProducerRecord KafkaError | The message could not be sent |
NoMessageError KafkaError | An error occurred, but librdkafka did not attach any sent message |
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 # |