kafka0.10 kafka-consumer-groups.sh的结果只有一个组:KafkaManagerOffsetCache。但是实际上集群中是有很多正在消费的组。这是为什么?

小小火柴 发表于: 2017-01-13   最后更新时间: 2017-01-13 15:17:21   8,406 游览
发表于 2017-01-13
添加评论

你的命令是什么?

小小火柴 -> 半兽人 7年前

./kafka-consumer-groups.sh --bootstrap-server :9092,*:9092 --list。结果只有一个KafkaManagerOffsetCache

半兽人 -> 小小火柴 7年前

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list

小小火柴 -> 半兽人 7年前

这个是取zk上的信息,也试过了,但是我的消费者组不是保存在zk上的

半兽人 -> 小小火柴 7年前

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list

小小火柴 -> 半兽人 7年前

默认就是new-consumer 。

半兽人 -> 小小火柴 7年前

如果你客户端用的是0.8以上的,用的是最新的客户端(bootstrap-server),那么用new-consumer能查到。0.8以下用zookeeper的就用zk的。

小小火柴 -> 半兽人 7年前

你可以试下,在消费者先消费,然后关闭。过会去运行命令是不行的。如果是消费者正在运行,那是可以的

半兽人 -> 小小火柴 7年前

这些命令都只能监控活跃的消费者。

小小火柴 -> 半兽人 7年前

我要监控所有的消费者呢

半兽人 -> 小小火柴 7年前

如果查寻不到就认为是异常

暗夜星辰 -> 半兽人 7年前

使用命令 bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list 能查询出a;
使用命令bin/kafka-consumer-groups.sh --zookeeper 192.168.0.20:5181 --list 能查出 b 和 c ;
在kafkaMonitor 中只显示 group b 和 c ,那么在哪里能监控c?? 求教

修改之前的问题,问题是在哪能监控a ? 

半兽人 -> 暗夜星辰 7年前

如果用的是KafkaOffsetMonitory,无法同时监控2个,需要指定不同的

暗夜星辰 -> 半兽人 7年前

多谢 .我重新下了 KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar , 执行 java -cp KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage kafka --zk q5:2181 --port 9988 --refresh 5.seconds --retain 2.days , 我已经指定是 kafka了,可监控页面还是看不到我的group.但执行 bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list  还是能看到有一个group,求教 

半兽人 -> 暗夜星辰 7年前

--offsetStorage zookeeper

暗夜星辰 -> 半兽人 7年前

我现在是想把offsetStorage 指定到kafka ,并且能在页面监控到这些group ? ?

你好,能加下qq么?请教些问题 qq:402075400

半兽人 -> 暗夜星辰 7年前

目前的版本没办法同时满足的。

暗夜星辰 -> 半兽人 7年前

消费端使用0.10.0.1 版本消费数据,产生的group有办法存储在zookooper中么?

半兽人 -> 暗夜星辰 7年前

配置 offsets.storage=zookeeper即从kafka切换到zookeeper中。

你的答案

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