Struct rdkafka::consumer::base_consumer::PartitionQueue
source · [−]pub struct PartitionQueue<C> where
C: ConsumerContext, { /* private fields */ }
Expand description
A message queue for a single partition.
Implementations
Polls the partition for new messages.
The timeout
parameter controls how long to block if no messages are
available.
Remember that you must also call BaseConsumer::poll
on the
associated consumer regularly, even if no messages are expected, to
serve callbacks.
Sets a callback that will be invoked whenever the queue becomes nonempty.