我想用java获取所有消费者组list以及消费的topic的offset,logsize等信息,kafka版本是0.10,Adminclient获取不到数据 只支持到v1,想问下还有哪种办法可以获取?






发表于: 5月前   最后更新时间: 5月前   游览量:1148
上一条: 到头了!
下一条: 已经是最后了!

  • 请问,用这个命令bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server A5-401-NF5280M4-2017-141:9092 --list 查询不到消费者组怎么办?
    你好,我也遇到了这个问题。那个java调用kafka 自带脚本的代码 可以发我邮箱吗hp957660233@foxmail.com。万分感谢!
    大佬~问题怎么解决的?求转发
    • 我一开始是拿到了所有的消费者组,然后新建了一个消费者去消费consumer_offsets,虽然能获取到所有东西但是发现数据量过大的情况下,遍历是不现实的 最后采用了jmx的方式去获取消费者偏移量,这种方式在kafka实战那本书中有些
        • ./bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 -list
          ./bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group console-consumer-69776 --describe
          ./bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic zll-topic --group console-consumer-69776 --zookeeper 127.0.0.1:2181
            • 我通过zk获取到了这些信息,但是从zk获取的groupid和我实际的groupid怎么对应?百度说一个是low level一个是high level的
                logsize 和logEndOffset用JMX都能拿到 消费组list还是可以用adminclient获取的 client.listAllGroupsFlattened()
                AdminClient已经不太支持了,你可以试试KafkaConsumer,这个类,如果很急的话,可以给我一个邮箱,我可以把我写的代码,给你参考一下