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 |
Information returned by the producer after a message has been delivered or failed to be delivered. |
EmptyProducerContext | |
FutureProducer |
A producer with an internal running thread. This producer doesn't neeed to be polled.
The internal thread can be terminated with the |
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. |
Traits
ProducerContext |
A ProducerContext is a Context specific for producers. It can be used to store user-specified
callbacks, such as |