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



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




上一条: 到头了!
下一条: 已经是最后了!

  • 我也遇到了这个问题 kafka 2.2.1版本 启动命令是 java -cp KafkaOffsetMonitor-assembly-0.3.0-SNAPSHOT.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --offsetStorage kafka --zk 192.168.5.148:2181 --port 9000 --refresh 10.seconds --retain 1.days
    不知道什么原因

    --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之间互通 就没问题。你主动运行一条消费者,在观察下。刚启动的时候,如果没有消费者运行,就不会展示。

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