apache-kafka - 尝试删除Kafka中的消费者组时出现GroupNotEmptyException

Question

我执行了

"kafka-consumer-groups --bootstrap-server localhost:9092 --list" 

这导致显示一组:console-consumer-961
然后我尝试删除这个组:

kafka-consumer-groups --bootstrap-server localhost:9092 --delete --group console-consumer-961

但这会导致异常:

Error: Deletion of some consumer groups failed:
* Group 'console-consumer-961' could not be deleted due to: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.GroupNotEmptyException: The group is not empty.

我猜这个组是在我运行 kafka 时创建的- console-consumer.bat ，但现在这个消费者没有运行。如何删除这个消费者组？

Answer 1

您可以使用 kafka-consumer-groups 来验证消费者组的状态。命令行工具。

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group console-consumer-961 --state

这将向您显示消费者的状态。如果它不为空，Kafka 将不允许删除该组。如果它仍然显示您的控制台使用者正在运行，您需要确保正确关闭它(通常通过 CTRL+C)