kafka低级消费者 消费情况可以查看吗?

领悟 发表于: 2020-05-08   最后更新时间: 2020-05-08 09:19:13   1,795 游览

请问 kafka低级消费者 消费情况可以查看吗?或者如何感知到低级消费者正在消费?谢谢!

发表于 2020-05-08
添加评论
## 显示某个消费组的消费详情(0.9版本 - 0.10.1.0 之前)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

可参考:https://www.orchome.com/454

领悟 -> 半兽人 4年前

谢谢,但是目前只能看到高级消费者的消费情况,低级消费者的没看到呢。

半兽人 -> 领悟 4年前

用这个

## 显示某个消费组的消费详情(仅支持offset存储在zookeeper上的)
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test
领悟 -> 半兽人 4年前

多谢!

小菜超、 -> 半兽人 4年前

could not find or load main class kafka.tools.consumeroffsetchecker 提示这个怎么处理? 目前服务端kafka是 kafka_2.12-2.5.0,想在服务端查看低版本的一些消费者组的情况,应该怎么查呀?

半兽人 -> 小菜超、 4年前

kafka在0.9.0.0版本之后,kafka.tools.ConsumerOffsetChecker已经不支持了
可参考:https://www.orchome.com/454
有对应的版本查询方式。

小菜超、 -> 半兽人 4年前

1:使用bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test
----提示could not find or load main class kafka.tools.consumeroffsetchecker
2:使用bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group
----提示new-consumer is not a recognized option
3:使用bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
----只能查到高版本消费者的group, 查不到低版本消费者的group

所以 大神帮忙看下怎么查低版本消费者的group信息呢?是我服务端安装或者配置有问题?

半兽人 -> 小菜超、 4年前

你下个低版本的kafka得了,对应你低版本的消费者,去查。
另外,kafka集群是高版本低,消费者怎么是低版本的?怪怪的。

小菜超、 -> 半兽人 4年前

谢啦, 看来目前只能用这种办法了;
PS:我们这边有部分老系统jdk版本低,只能用低版本的消费者,所以出现这种情况。

你的答案

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