没有获得kafka consumer jmx metrics的records-lag-max值

Question

我正在运行启用了JMX的java kafka流应用程序。我试图获取消费者滞后，但为应用程序拥有的所有消费者获得无限。

我正在寻找以下jmx指标：

kafka.consumer.type_consumer-fetch-manager-metrics.client-id_consumer-v1*.records-lag-max

我不确定为什么它没有给出确切的价值。请告诉我：

• 如果我在这里遗失了什么，
• 或者，查看错误的指标，
• 或者需要做一些额外的配置来消除消费者的滞后。

提前致谢 ！！！

Answer 1

我找到了这个问题的原因。实际上，在消费者滞后的情况下，我的服务正在重试无限的时间来连接到数据库，该数据库正在弯曲消费者以生成指标，因此，我得到的价值是无限的。

因此，JMX方面没有任何问题，导致问题的是用例。