我个人从我的消费者那里直接查询jmx信息。我只用Java消费，因此JMX bean
kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*/records-lag-max是可用的。
如果jolokia在您的类路径中，则可以使用GET检索值
/jolokia/read/kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*/records-lag-max并将所有结果收集在一个位置。
还有Burrow，它很容易配置，但是有点过时了（如果我记得很好的话，对于0.10不起作用）。
