Enum rdkafka::consumer::Rebalance

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

Rebalance information.

Variants

Assign(&'a TopicPartitionList)

A new partition assignment is received.

Tuple Fields of Assign

0: &'a TopicPartitionList

Revoke

All partitions are revoked.

Error(String)

Unexpected error from Kafka.

Tuple Fields of Error

0: String

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.