Я тестировал потоковое приложение Kafka. Возможно, что в какой-то момент приложение могло нечисто завершить работу во время тестирования, и теперь у меня есть данные группы потребителей, от которых я не могу избавиться.
Если я попытаюсь ...
Kafka-consumer-groups —group testgrp —delete
... выдает следующую ошибку:
Error: Deletion of some consumer groups failed:
Group ‘testgrp’ could not be deleted due to: java.util.ExecutionException: .org.apache.kafka.common.errors.GroupNotException: The group is not empty
Сброс смещений дает еще одну ошибку, заявляющую:
Assignments can only be reset if the group is inactive , but the current state is Stable.
Когда я описываю состояние, оно показывает, что состояние Стабильно, но я подтвердил, что клиентское приложение завершилось, и процесс зомби не запущен.
Есть ли способ очистить информацию и состояние члена группы потребителей, не удаляя все метаданные брокера / зоопарка?