我花了一整天的时间在网上搜索，但没有一个有效的例子。我想要的只是给定groupid的消费者组延迟度量（或其派生自、当前和最后的2个偏移量）。我使用Kafka0.9+（所以没有在zookeeper偏移），也可以使用新的，如果需要的。我需要一种方式来获得它的编程，而不是使用脚本。有人，求你了，我怎么得到它？？？？？
vsmadaxz1#
目前正在添加通过adminclient检索消费者组详细信息的方法，请参阅https://cwiki.apache.org/confluence/pages/viewpage.action?pageid=74686265.同时，最好的选择是重用 kafka-consumer-group 工具。它由以下scala类支持：https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/consumergroupcommand.scala 而且提取用于检索组中所有示例的详细信息的位应该不是很难。
kafka-consumer-group
1条答案
按热度按时间vsmadaxz1#
目前正在添加通过adminclient检索消费者组详细信息的方法，请参阅https://cwiki.apache.org/confluence/pages/viewpage.action?pageid=74686265.
同时，最好的选择是重用
kafka-consumer-group工具。它由以下scala类支持：https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/admin/consumergroupcommand.scala 而且提取用于检索组中所有示例的详细信息的位应该不是很难。