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






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

评论…


  • logsize 和logEndOffset用JMX都能拿到 消费组list还是可以用adminclient获取的 client.listAllGroupsFlattened()
    AdminClient已经不太支持了,你可以试试KafkaConsumer,这个类,如果很急的话,可以给我一个邮箱,我可以把我写的代码,给你参考一下
  • 评论…
    • in this conversation