Confluent Cloud中空ID Kafka消费者组的成因与删除方法

调用Confluent Cloud Kafka REST接口{confluentUrl}/kafka/v3/clusters/{cluster_id}/consumer-groups查询消费组列表时，查到的特殊条目字段如下：

"consumer_group_id": "",
"is_simple": true,
"partition_assignor": "",
"state": "EMPTY",

该条目显示对应主题存在约10万条消费滞后，集群其余组件运行状态正常。

• 该条目不是异常创建的正式消费者组，是Kafka为**未配置group.id的独立消费者（手动调用assign()方法指定消费分区、不通过消费组协议做自动分区分配的客户端）**生成的虚拟统计条目。这类客户端消费时不会加入任何正式消费者组，Kafka在归集全集群消费位点、消费滞后指标时，会把所有这类无组ID的独立消费者的消费数据统一归集到ID为空的虚拟组条目下。
• 条目里is_simple: true就是用来标记该条目对应的是简单/独立消费者，而非标准消费组；因为不存在组协调、分区分配的流程，所以partition_assignor字段为空，状态固定显示为EMPTY。
• 你看到的10万条消费滞后，实际是集群中运行的某台/多台未配置group.id的独立消费者的消费滞后数据，不是这个空条目本身产生的。

• 这个空ID虚拟条目不支持手动删除，也没有必要手动删除。常规消费组的删除操作（包括REST接口删除、kafka-consumer-groups.sh --delete命令删除）仅对注册在组协调者上、有合法非空ID的正式消费组生效，对这类统计占位条目不会起作用。
• 要让该条目从查询结果中消失，只需要找到集群中未配置group.id的独立消费者进程：要么停掉该进程，要么为其配置合法的group.id参数后重启，等对应旧的消费位点数据超过保留期自动清理后，这个空ID条目就会自动消失，对应的滞后统计也会同步清除。
• 排查这类独立消费者时，可以通过Confluent Cloud控制台的客户端监控、或者broker的客户端连接日志定位，不要直接操作主题分区的位点数据，避免影响其他正常运行的消费组业务。

内容的提问来源于stack exchange，提问作者Avocado