Kafka 消费者组元数据

Question

Kafka 版本 2.4.1 动物园管理员 3.4.10

我在删除由 kafka 流应用程序创建的消费者组时遇到问题。即使应用程序已关闭，但该组始终将其报告为 'rebalancing' 状态。 kafka-consumer-groups 不允许我删除它，因为它说 'The group is not empty'

参考：

问题：

1. 消费者组信息存储在哪里？ （我试过 zkcli.sh 命令，但 /consumers 是空的）

2. 组协调器在哪里存储与消费者及其状态相关的信息

3. 是否有其他命令可用于查询组信息（或任何 hack）
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. Where are consumer group members stored ?

消费者组的元数据存储在内部主题中。