Struct rdkafka::statistics::ConsumerGroup
source · [−]pub struct ConsumerGroup {
pub state: String,
pub stateage: i64,
pub join_state: String,
pub rebalance_age: i64,
pub rebalance_cnt: i64,
pub rebalance_reason: String,
pub assignment_size: i32,
}
Expand description
Consumer group manager statistics.
Fields
state: String
The local consumer group handler’s state.
stateage: i64
The time elapsed since the last state change, in milliseconds.
join_state: String
The local consumer group hander’s join state.
rebalance_age: i64
The time elapsed since the last rebalance (assign or revoke), in milliseconds.
rebalance_cnt: i64
The total number of rebalances (assign or revoke).
rebalance_reason: String
The reason for the last rebalance.
This string will be empty if no rebalances have occurred.
assignment_size: i32
The partition count for the current assignment.
Trait Implementations
Returns the “default value” for a type. Read more
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more