Как убрать несвежего потребителя из брокера кафки?

Question

kafka-consumer-groups.sh --bootstrap-server hostname:port --describe --group sub1

Группа потребителей 'sub1' не имеет активных членов.

kafka-consumer-groups.sh --bootstrap-server hostname:port --delete --group sub1

Опция '[delete]' действительна только для '[zookeeper]'.

Обратите внимание, что нет необходимости удалять метаданные группы для нового потребителя, поскольку группа удаляется, когда истекает последнее зафиксированное смещение для этой группы.

Также, когда я пытаюсь отобразить мойДанные о потребителе, использующие zookeeper, сообщают, что потребитель "sub1" недоступен.

kafka-consumer-groups.sh --zookeeper hostname:port --describe --group sub1

Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).

Error: The consumer group 'sub1' does not exist. 

Answer 1

Групповая информация для потребителей, которые используют Kafka для управления смещениями вместо Zookeeper, не может быть удалена встроенными инструментами.Если вы прочитали все предупреждение при попытке выполнить

kafka-consumer-groups.sh --bootstrap-server hostname:port --delete --group sub1

, в нем четко указывается, почему нельзя удалить информацию метаданных группы:

Option '[delete]' is only valid with '[zookeeper]'.
Note that there's no need to delete group metadata for the new consumer as the group is deleted when the last committed offset for that group expires.