Struct ClassicProtocol 

pub struct ClassicProtocol { /* private fields */ }

The classic protocol: JoinGroup, SyncGroup, Heartbeat.

Implementations

impl ClassicProtocol

pub fn new( group_id: impl Into<String>, topics: Vec<String>, assignor: Box<dyn Assignor>, ) -> Self

pub fn member(&self) -> &GroupMember

pub fn set_session_timeout(&mut self, ms: i32)

How long the coordinator waits for a heartbeat before removing us.

pub fn set_rebalance_timeout(&mut self, ms: i32)

How long the coordinator waits for every member to rejoin. Should exceed the longest a caller can spend between polls, or a slow consumer is dropped mid-rebalance.

Trait Implementations

impl<T: Transport> GroupProtocol<T> for ClassicProtocol

async fn advance(&mut self, cluster: &mut Cluster<T>) -> Result<Membership>

Drive one step of membership. Called until it reports Membership stable.

async fn commit( &mut self, cluster: &mut Cluster<T>, offsets: &BTreeMap<TopicPartition, i64>, ) -> Result<()>

Commit these offsets for the group.

fn topics(&self) -> Vec<String>

What this member is subscribed to, so the caller can watch those topics for changes the group must agree on.

fn request_rejoin(&mut self)

Ask to rejoin the group at the next Self::advance.

fn group_metadata(&self) -> Option<GroupMetadata>

What proves this member is current, for a transactional producer.

async fn committed( &mut self, cluster: &mut Cluster<T>, partitions: &[TopicPartition], ) -> Result<BTreeMap<TopicPartition, i64>>

Where this group last committed, for the partitions given.

async fn leave(&mut self, cluster: &mut Cluster<T>) -> Result<()>

Leave deliberately, so the group rebalances now rather than at the session timeout.