apache-kafka - Kafka Consumer Group状态解释

标签 apache-kafka

我在 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 节点中删除。这可能是由于不活动,或者该组正在迁移到不同的组协调员。

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

关于apache-kafka - Kafka Consumer Group状态解释,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57253964/

相关文章:

apache-kafka - 防止kafka消费者长时间超时

java - 指定 Kafka 生产者的分区数

apache-kafka - Kafka准备好用于生产了吗?

spring-boot - Spring Boot 2 和 Spring Boot 3 上的应用程序之间的跟踪

java - 使用java的play框架中的Kafka Consumer

security - 哪个是kafka安全中最好的身份验证机制?

apache-kafka - Kafka 缓冲区大小和时间间隔

apache-spark - 驱动程序停止后,Spark流作业失败

node.js - 如何使用 kafka-node 控制消费的 kafka 消息的提交

apache-kafka - 如何使用 Kafka 中的整数序列化器将整数值传递给 kafka 生产者并在 kafka 消费者控制台上读回