Struct ConsumerGroup 

pub struct ConsumerGroup { /* private fields */ }

Shared state for a consumer group.

Implementations

impl ConsumerGroup

pub fn new( group_name: &str, topic_name: &str, num_partitions: u32, stale_threshold_secs: u64, ) -> Self

Create a new consumer group.

pub fn claim(&mut self, consumer_id: &str) -> Vec<u32>

Claim unclaimed or stale partitions for the given consumer.

Returns the list of partition indices now assigned to this consumer.

pub fn assigned_to(&self, consumer_id: &str) -> Vec<u32>

Return the partitions currently assigned to the given consumer.

pub fn heartbeat(&mut self, consumer_id: &str)

Update the heartbeat for a consumer’s assigned partitions.

pub fn release(&mut self, consumer_id: &str)

Release all partitions held by the given consumer.

pub fn group_name(&self) -> &str

Returns the group name.

pub fn topic_name(&self) -> &str

Returns the topic name.

pub fn unassigned_count(&self) -> u32

Returns the number of unassigned partitions.