从字面上看，我已经整整一天梳理了一整天，并没有一个好的例子。
我想要的是对于给定的groupID，消费者群体滞后度量（或者从其导出的2个偏移，当前和最后一个）。
我使用kafka 0.9+（所以在zookeeper中没有偏移），如果需要也可以使用更新的。
我需要一种以编程方式获取它的方法，而不是使用脚本。
有人，请问，我怎么得到它?????
目前正在开展工作以添加通过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，提取检索组中所有实例的详细信息的位应该不是很难。