Struct ConsumerRebalanceListener 

pub struct ConsumerRebalanceListener { /* private fields */ }

Synchronous callback invoked when a group consumer assignment changes.

Implementations

impl ConsumerRebalanceListener

pub fn new( callback: impl Fn(ConsumerRebalanceEvent) + Send + Sync + 'static, ) -> Self

Creates a new rebalance listener.

pub fn on_rebalance(&self, event: ConsumerRebalanceEvent)

Invokes the callback.

Trait Implementations

impl Clone for ConsumerRebalanceListener

fn clone(&self) -> ConsumerRebalanceListener

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumerRebalanceListener

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

Formats the value using the given formatter.