我正在运行一个启用jmx的javakafka流应用程序。我试图获取消费者滞后,但对于应用程序所拥有的所有消费者来说,获得无穷大。
我正在查看以下jmx指标:
kafka.consumer.type_consumer-fetch-manager-metrics.client-id_consumer-v1*.records-lag-max
我不知道为什么它没有给出确切的值。请告诉我:
如果我错过了什么,
或者,寻找错误的指标,
或者需要做一些额外的配置,以获得消费者滞后。
提前谢谢!!!
我正在运行一个启用jmx的javakafka流应用程序。我试图获取消费者滞后,但对于应用程序所拥有的所有消费者来说,获得无穷大。
我正在查看以下jmx指标:
kafka.consumer.type_consumer-fetch-manager-metrics.client-id_consumer-v1*.records-lag-max
我不知道为什么它没有给出确切的值。请告诉我:
如果我错过了什么,
或者,寻找错误的指标,
或者需要做一些额外的配置,以获得消费者滞后。
提前谢谢!!!
1条答案
按热度按时间nhhxz33t1#
我知道问题的原因了。实际上,在消费者滞后的情况下,我的服务正在无限次地重试连接到数据库,这使得消费者无法生成度量,因此,我得到的值是无限的。
因此,jmx方面没有什么问题,是用例导致了问题。