返回到文章

采纳

编辑于 2年前

Kafka consumer group 无法删除 Group 'xx' could not be deleted due to: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.GroupNotEmptyException: The group is not empty

kafka

Kafka Version:2.8.0

Kafka delete consumer "**test-consumer-group**",but the current state is Stable

上述报错,但是通过kafka-consumer-group.sh --all-groups/--members/--state查看数据存在前后不一致;

kafka all-groups

kafka members

kafka all-state

  1. 已经尝试过将Kafka集群3个节点,整体重启;
  2. 已排查client端无业务代码调用;

诉求:

1、如何将test-consumer-group进行删除,如何进行排查;
2、为什么通过kafka-consumer-group.sh获取的数据,存在前后不一致;