我在 ConsumerGroupState
中看到了以下常量。什么情况会导致消费者组处于 DEAD 或 UNKNOWN 状态?
UNKNOWN("Unknown"),
PREPARING_REBALANCE("PreparingRebalance"),
COMPLETING_REBALANCE("CompletingRebalance"),
STABLE("Stable"),
DEAD("Dead"),
EMPTY("Empty");
我认为 EMPTY 意味着成员是空的。 PREPARING_REBALANCE 表示新消费者加入/老消费者离开,COMPLETING_REBALANCE 类似。
我的目标是找到一个指示消费者组不活跃的状态,据我所知,我可以简单地采用 EMPTY 状态。
最佳答案
- 空:群组存在但没有人在里面
- 稳定:再平衡已经发生,消费者消费愉快。
- PreparingRebalance:发生了一些变化,需要重新分配分区,因此 Kafka 正在重新平衡。
- CompletingRebalance:Kafka 仍在重新平衡组。为什么有两个州?稍后会详细介绍。
- Dead:该组即将从该 Kafka 节点中删除。这可能是由于不活动,或者该组正在迁移到不同的组协调员。
关于apache-kafka - Kafka Consumer Group状态解释,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57253964/