Struct rdkafka::consumer::base_consumer::PartitionQueue

pub struct PartitionQueue<C> where
    C: ConsumerContext,  { /* 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.