Module rdkafka::producer [−] [src]

Producer implementations.

Structs

BaseProducer	Contains a reference counted producer client. It can be safely cloned to create another reference to the same producer.
DeliveryFuture	A future that will receive a `DeliveryStatus` containing information on the delivery status of the message.
DeliveryStatus	Information returned by the producer after a message has been delivered or failed to be delivered.
FutureProducer	A producer with an internal running thread. This producer doesn't neeed to be polled. The internal thread can be terminated with the `stop` method or moving the `ProducerPollingThread` out of scope.
FutureProducerContext	The ProducerContext used by the FutureProducer. This context will use a Future as its DeliveryContext and will complete the future when the message is delivered (or failed to). All other callbacks will be delegated to the wrapped ProducerContext.

A ProducerContext is a Context specific for producers. It can be used to store user-specified callbacks, such as delivery.