尝试删除 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工具仍然无法删除新样式的消费者组，但是你的底层问题已经解决了。

在 Kafka 0.10.2 之前，有 hack，但没有干净的解决方案。

Answer 2

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

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

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

尝试删除 Kafka 中的消费者组时获取 GroupNotEmptyException

Getting GroupNotEmptyException when trying to delete a consumer group in Kafka

apache-kafka

kafka-consumer-api