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

Question

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

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

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

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.