Enum rdkafka::consumer::Rebalance [−][src]
pub enum Rebalance<'a> {
Assign(&'a TopicPartitionList),
Revoke(&'a TopicPartitionList),
Error(String),
}
Expand description
Rebalance information.
Variants
Assign(&'a TopicPartitionList)
Tuple Fields
0: &'a TopicPartitionList
A new partition assignment is received.
Revoke(&'a TopicPartitionList)
Tuple Fields
0: &'a TopicPartitionList
A new partition revocation is received.
Error(String)
Tuple Fields
0: String
Unexpected error from Kafka.
Trait Implementations
Auto Trait Implementations
impl<'a> RefUnwindSafe for Rebalance<'a>
impl<'a> UnwindSafe for Rebalance<'a>
Blanket Implementations
Mutably borrows from an owned value. Read more