KafkaOffsetMonitor: Unable to find Active Consumers

善鬼 发表于: 2019-04-26   最后更新时间: 2019-04-27  

提问说明

Kafka 版本是2.11

KafkaOffsetMonitor启动脚本:

java -cp /usr/local/KafkaOffsetMonitor/KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage zookeeper --zk IP:2181 --port 9595 --refresh 6.seconds --retain 2.days

结果Consumer group 空白。可以获取到topic list,但是每个topic下面显示Unable to find Active Consumers



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容





发表于: 4月前   最后更新时间: 3月前   游览量:536
上一条: 如何获取kafka的logSize,offSize,lag呢
下一条: KafkaOffsetMonitor为什么只显示kafka集群中的一个节点

  • --offsetStorage kafka 改成这个。

    • 而且我的日志中,只有一句serving resources from: jar:file:/usr/local/KafkaOffsetMonitor/KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar!/offsetapp 没有报错
        • 先用命令试试。 ## 新消费者列表查询(支持0.9版本+) bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list ## 显示某个消费组的消费详情(支持0.9版本+) bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group
            • 第一个命令显示我又一个消费者 test-consumer-group 第二个命令显示了topic的信息 TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID defaultKJLog 0 44440 44440 0 consumer-1-1f4eefca-0a16-477f-8230-b8cc07ca970f /58.251.50.XX consumer-1 defaultKJLog 1 62994620 62994620 0 consumer-1-1f4eefca-0a16-477f-8230-b8cc07ca970f /58.251.50.XX consumer-1 defaultKJLog 2 314 314 0 consumer-1-1f4eefca-0a16-477f-8230-b8cc07ca970f /58.251.50.XX consumer-1 defaultKJLog 3 87 87 0 consumer-1-1f4eefca-0a16-477f-8230-b8cc07ca970f /58.251.50.XX consumer-1
                • 而且我运行完KafkaOffsetMonitor的启动脚本后,只有两行日志就再没有了 serving resources from: jar:file:/usr/local/server/KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar!/offsetapp 2019-05-05 07:43:36 WARN AppInfo$:83 - Can't read Kafka version from MANIFEST.MF. Possible cause: java.lang.NullPointerException
                    • 我KafkaOffsetMonitor运行的机器和Kafka运行的机器隔了网络,只开放了2181和9092端口,中间还有其他的端口么 ?刚刚执行了你的两个命令后。本地的KafkaOffsetMonitor已经正常,但是隔网络的KafkaOffsetMonitor依旧是Unable to find Active Consumers
                        • 隔网络的只要kafka之间互通 就没问题。你主动运行一条消费者,在观察下。刚启动的时候,如果没有消费者运行,就不会展示。

                            如果没有消费者,第一次就会空的。