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
## 显示某个消费组的消费详情(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
谢谢,但是目前只能看到高级消费者的消费情况,低级消费者的没看到呢。
用这个
## 显示某个消费组的消费详情(仅支持offset存储在zookeeper上的) bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test
多谢!
could not find or load main class kafka.tools.consumeroffsetchecker 提示这个怎么处理? 目前服务端kafka是 kafka_2.12-2.5.0,想在服务端查看低版本的一些消费者组的情况,应该怎么查呀?
kafka在
0.9.0.0
版本之后,kafka.tools.ConsumerOffsetChecker已经不支持了可参考:https://www.orchome.com/454
有对应的版本查询方式。
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信息呢?是我服务端安装或者配置有问题?
你下个低版本的kafka得了,对应你低版本的消费者,去查。
另外,kafka集群是高版本低,消费者怎么是低版本的?怪怪的。
谢啦, 看来目前只能用这种办法了;
PS:我们这边有部分老系统jdk版本低,只能用低版本的消费者,所以出现这种情况。
你的答案