Struct Consumer 

pub struct Consumer { /* private fields */ }

A consumer that reads from specific partitions of a topic.

Implementations

impl Consumer

pub fn new(topic_name: &str, group: &str) -> Self

Create a new consumer for the named topic and consumer group.

pub fn assign(&mut self, partitions: &[u32])

Assign specific partitions to this consumer.

pub fn seek( &mut self, mgr: &TopicManager, offset_store: &dyn OffsetStore, policy: SeekPolicy, ) -> Result<()>

Initialize read offsets according to the seek policy.

pub fn poll( &mut self, mgr: &TopicManager, max_messages: usize, ) -> Result<Vec<(u32, Message)>>

Poll for the next batch of messages across all assigned partitions.

Returns up to max_messages messages. Messages are interleaved across partitions in round-robin order.

pub fn commit(&self, offset_store: &mut dyn OffsetStore)

Commit the current read offsets to the offset store.

pub fn assigned_partitions(&self) -> &[u32]

Returns the assigned partitions.

pub fn group(&self) -> &str

Returns the consumer group name.