Enum rdkafka::consumer::Rebalance

pub enum Rebalance<'a> {
    Assign(&'a TopicPartitionList),
    Revoke(&'a TopicPartitionList),
    Error(String),
}

Rebalance information.

Variants

Assign(&'a TopicPartitionList)

A new partition assignment is received.

Revoke(&'a TopicPartitionList)

A new partition revocation is received.

Error(String)

Unexpected error from Kafka.

Trait Implementations

impl<'a> Clone for Rebalance<'a>

fn clone(&self) -> Rebalance<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Rebalance<'a>

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

Formats the value using the given formatter.