Kafka ConsumerGroupState解释

Question

我在 中看到了以下常量ConsumerGroupState。什么情况会导致消费者组处于 DEAD 或 UNKNOWN 状态？

UNKNOWN("Unknown"),
PREPARING_REBALANCE("PreparingRebalance"),
COMPLETING_REBALANCE("CompletingRebalance"),
STABLE("Stable"),
DEAD("Dead"),
EMPTY("Empty");

我认为 EMPTY 意味着成员是空的。PREPARING_REBALANCE 表示新消费者加入/旧消费者离开，COMPLETING_REBALANCE 与之类似。

我的目标是找到一个表明消费者组处于非活动状态的状态，据我了解，我可以简单地采用 EMPTY 状态。

Answer 1

• 空：该组存在但没有人在其中
• 稳定：重新平衡已经发生，消费者正在愉快地消费。
• PreparingRebalance：有些东西发生了变化，需要重新分配分区，所以Kafka是重新平衡的中间。
• CompletingRebalance：Kafka 仍在重新平衡组。为什么有 2 个状态呢？稍后会详细介绍。
• Dead：该组很快就会从该 Kafka 节点中删除。这可能是由于不活动，或者该组正在迁移到不同的组协调器。

摘自https://chrzaszcz.dev/2019/06/kafka-rebalancing/