Enum ConsumerRebalanceEvent 

pub enum ConsumerRebalanceEvent {
    Revoked(Vec<TopicPartition>),
    Assigned(Vec<TopicPartition>),
    Lost(Vec<TopicPartition>),
}

Consumer rebalance notification.

Variants

Revoked(Vec<TopicPartition>)

Partitions were revoked before being removed from the active assignment.

Assigned(Vec<TopicPartition>)

Partitions were added to the active assignment.

Lost(Vec<TopicPartition>)

Partitions were lost and should not be committed by the callback.

Implementations

impl ConsumerRebalanceEvent

pub fn partitions(&self) -> &[TopicPartition]

Returns the affected partitions.

Trait Implementations

impl Clone for ConsumerRebalanceEvent

fn clone(&self) -> ConsumerRebalanceEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerRebalanceEvent

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

Formats the value using the given formatter.

impl PartialEq for ConsumerRebalanceEvent

fn eq(&self, other: &ConsumerRebalanceEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ConsumerRebalanceEvent

impl StructuralPartialEq for ConsumerRebalanceEvent