Kafka消费者集团元数据

Question

Kafka 2.4.1Zookeeper 3.4.10版本。

我在删除kafka流应用所创建的消费者组时遇到了问题，即使应用已经关闭，但该组总是报告为 "重新平衡 "状态。即使应用程序已关闭，但该组总是报告为 "重新平衡 "状态。 而且kafka-consumer-groups不允许我删除它，因为它说 "该组不是空的"。

参考。消费者群体陷于 "再平衡 "即使没有消费者

问题。

1. 消费者组信息存储在哪里？ (我试过zkcli.sh命令，消费者是空的)

2. 集团协调人在哪里存储与消费者相关的信息&其状态。

3. 是否有其他命令可以用来查询组信息（或任何黑客）。
4. 消费群成员存储在哪里？

Answer 1

为了列出所有的消费群组

bin/kafka-consumer-groups.sh  \
  --bootstrap-server localhost:9092 \
  --list 

---

现在，要获得特定消费者群体的信息，你只需运行

bin/kafka-consumer-groups.sh \
    --bootstrap-server localhost:9092 \
    --describe \
    --group my-consumer-group

---

4. 消费群组成员存储在哪里？

消费群的元数据存储在内部的主题中。__consumer_offsets.