Struct rdkafka::consumer::base_consumer::PartitionQueue

pub struct PartitionQueue<C>
where
    C: ConsumerContext + 'static,
{ /* private fields */ }

A message queue for a single partition.

Implementations

impl<C> PartitionQueue<C>

where C: ConsumerContext,

pub fn poll<T: Into<Timeout>>( &self, timeout: T, ) -> Option<KafkaResult<BorrowedMessage<'_>>>

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.

pub fn set_nonempty_callback<F>(&mut self, f: F)

where F: Fn() + Send + Sync + 'static,

Sets a callback that will be invoked whenever the queue becomes nonempty.

Trait Implementations

impl<C> Drop for PartitionQueue<C>

where C: ConsumerContext,

fn drop(&mut self)

Executes the destructor for this type.