Struct ConsumerGroupManager 

pub struct ConsumerGroupManager { /* private fields */ }

Manages consumer groups for the Kafka broker

Implementations

impl ConsumerGroupManager

pub fn new() -> Self

Create a new consumer group manager

impl ConsumerGroupManager

pub fn groups(&self) -> &HashMap<String, ConsumerGroup>

Get a reference to all groups (for internal use)

pub async fn join_group( &mut self, group_id: &str, member_id: &str, client_id: &str, ) -> Result<JoinGroupResponse, Error>

Join a consumer group

pub async fn sync_group( &mut self, group_id: &str, assignments: Vec<PartitionAssignment>, topics: &HashMap<String, Topic>, ) -> Result<(), Error>

Sync group assignment

pub async fn commit_offsets( &mut self, group_id: &str, offsets: HashMap<(String, i32), i64>, ) -> Result<(), Error>

Commit consumer offsets

pub fn get_committed_offsets( &self, group_id: &str, ) -> HashMap<(String, i32), i64>

Get committed offsets for a group

pub async fn simulate_lag( &mut self, group_id: &str, topic: &str, lag: i64, topics: &HashMap<String, Topic>, )

Simulate consumer lag

pub async fn trigger_rebalance(&mut self, group_id: &str)

Trigger rebalance for a group

pub async fn reset_offsets( &mut self, group_id: &str, topic: &str, to: &str, topics: &HashMap<String, Topic>, )

Reset consumer offsets

Trait Implementations

impl Debug for ConsumerGroupManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConsumerGroupManager

fn default() -> Self

Returns the “default value” for a type.