Enum rdkafka::consumer::Rebalance [−][src]
pub enum Rebalance<'a> { Assign(&'a TopicPartitionList), Revoke, Error(String), }
Rebalance information.
Variants
Assign(&'a TopicPartitionList)
A new partition assignment is received.
Revoke
All partitions are revoked.
Error(String)
Unexpected error from Kafka.
Trait Implementations
impl<'a> Clone for Rebalance<'a>
[src]
impl<'a> Clone for Rebalance<'a>
fn clone(&self) -> Rebalance<'a>
[src]
fn clone(&self) -> Rebalance<'a>
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
1.0.0
[src]Performs copy-assignment from source
. Read more
impl<'a> Debug for Rebalance<'a>
[src]
impl<'a> Debug for Rebalance<'a>