Module rdkafka::consumer::base_consumer
[−]
[src]
Low level consumer wrapper.
Structs
| BaseConsumer |
Low level wrapper around the librdkafka consumer. This consumer requires to be periodically polled to make progress on rebalance, callbacks and to receive messages. |