如何在Java程序中获取卡夫卡消耗滞后

如何在Java程序中获取卡夫卡消耗滞后

我个人从我的消费者那里直接查询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不起作用）。