kafka版本: 0.10.1.x 现象: 命令行消费可以使用kafka-consumer-groups.sh 可以查看到对应的消费组 java代码消费无法用kafka-consumer-groups.sh查看对应消费组 使用kafka-tool工具查看,可以查看到所有消费组 确认消费组没有在zk中存储,全部由broker存储 消费者都提交了offset信息到__consumer_offsets中
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
0.10.1版本后,要标识的。 --new-consumer
这个参数应该是默认的,而且显式的加上也是相同的结果,还能从其他方面查查么,有啥建议没有?
0.10.1是要加标识的呀,那时候默认还没做好。
你的问题是?java代码消费无法用kafka-consumer-groups.sh查看对应消费组
是的,java代码消费的消费组,用kafka-consumer-groups.sh查看不到,但是用工具kafka-tool可以看到。 用命令行消费的消费组是可以看到的。
你是直接用java操作脚本,理论上跟你直接执行脚本效果是一致的。
这个问题解决了吗,我现在也遇到相同的问题了
我这应该是kafka客户端和kafka集群版本不一致导致的
我这边是因为用了listAllgroup有的没查到,用listFlattenGroup就都查到了
你的答案