kafka-consumer-groups.sh无法查看到所有消费组

医心/i 发表于: 2019-08-01   最后更新时间: 2019-08-01 16:56:14   7,040 游览

kafka版本: 0.10.1.x

现象: 命令行消费可以使用kafka-consumer-groups.sh 可以查看到对应的消费组
java代码消费无法用kafka-consumer-groups.sh查看对应消费组
使用kafka-tool工具查看,可以查看到所有消费组

 确认消费组没有在zk中存储,全部由broker存储

消费者都提交了offset信息到__consumer_offsets中

发表于 2019-08-01
添加评论

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
0.10.1版本后,要标识的。 --new-consumer

医心/i -> 半兽人 5年前

这个参数应该是默认的,而且显式的加上也是相同的结果,还能从其他方面查查么,有啥建议没有?

半兽人 -> 医心/i 5年前

0.10.1是要加标识的呀,那时候默认还没做好。
你的问题是?java代码消费无法用kafka-consumer-groups.sh查看对应消费组

医心/i -> 半兽人 5年前

是的,java代码消费的消费组,用kafka-consumer-groups.sh查看不到,但是用工具kafka-tool可以看到。 用命令行消费的消费组是可以看到的。

半兽人 -> 医心/i 5年前

你是直接用java操作脚本,理论上跟你直接执行脚本效果是一致的。

这个问题解决了吗,我现在也遇到相同的问题了

医心/i -> 飞扬 4年前

我这应该是kafka客户端和kafka集群版本不一致导致的

飞扬 -> 医心/i 4年前

我这边是因为用了listAllgroup有的没查到,用listFlattenGroup就都查到了

你的答案

查看kafka相关的其他问题或提一个您自己的问题