Удалить группу потребителей, созданную из слушателя java spring Kafka

Question

Я использую Spring kafka listener для чтения сообщений из темы kafka.

@KafkaListener( id = "member-group", topics = "member-updated" )

Я использовал для создания новой группы потребителей каждый раз (путем изменения вышеуказанного идентификатора группы), чтобы использовать все записи. Сейчас у меня около 50 групп потребителей, и я хочу их удалить. Я пытался удалить из кафки windows client -

kafka-consumer-groups.bat --zookeeper <zookeeper-url> --delete --group <group-name>

но это не удалось со следующим выводом -

Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).
Error: Delete for group '<group-name>' failed because group does not exist.

Так есть ли способ удалить эти группы потребителей с помощью кода или с помощью другого инструмента. И какова политика хранения по умолчанию для группы потребителей.

Answer 1

Использование --bootstrap-server host:port вместо --zookeeper,

Запустите скрипт без параметров, чтобы получить помощь...

--bootstrap-server <String: server to   REQUIRED (for consumer groups based on 
  connect to>                             the new consumer): The server to     
                                          connect to.                          
...
--zookeeper <String: urls>              REQUIRED (for consumer groups based on 
                                          the old consumer): The connection    
                                          string for the zookeeper connection  
                                          in the form host:port. Multiple URLS 
                                          can be given to allow fail-over.