Enum rdkafka::consumer::Rebalance

pub enum Rebalance {
    Assign(TopicPartitionList),
    Revoke,
    Error(String),
}

Contains rebalance information.

Variants

Assign(TopicPartitionList)RevokeError(String)

Trait Implementations

impl Clone for Rebalance

fn clone(&self) -> Rebalance

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Rebalance

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.