Kafka Consumer Group Метаданные

Question

Kafka Версия 2.4.1 Zookeeper 3.4.10

У меня проблемы с удалением группы потребителей, созданной приложением kafka streams. Несмотря на то, что приложение не работает, но группа всегда сообщает о состоянии «перебалансировки». И kafka-consumer-groups не позволяет мне удалить его, так как там написано: «Группа не пуста»

См .: Группа потребителей застряла в «ребалансировке», хотя потребителей нет

Вопросы:

1. Где хранится информация о группах потребителей? (Я пробовал команду zkcli. sh и / потребители пустые)

2. Где координатор группы хранит информацию, связанную с потребителем и его состоянием

3. Есть ли другие команды, которые можно использовать для запроса информации о группе (или любого другого хака)
4. Где хранятся члены группы потребителей?

Answer 1

Чтобы получить список всех групп потребителей

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

---

Теперь, чтобы получить информацию о конкретной группе потребителей c, вы можете просто запустить

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

---

Где хранятся члены группы потребителей?

Метаданные групп потребителей хранятся во внутренней топи c __consumer_offsets.