有一个有用的指标来监测Kafka消费滞后 spring-kafka
打电话 kafka_consumer_records_lag_max_records
. 但这个指标对事务性消费者不起作用。是否有特定的配置来为事务使用者启用滞后度量?
我已将我的消费者组配置为使用隔离级别 read_committed
度量包含 kafka_consumer_records_lag_max_records{client_id="listener-1",} -Inf
有一个有用的指标来监测Kafka消费滞后 spring-kafka
打电话 kafka_consumer_records_lag_max_records
. 但这个指标对事务性消费者不起作用。是否有特定的配置来为事务使用者启用滞后度量?
我已将我的消费者组配置为使用隔离级别 read_committed
度量包含 kafka_consumer_records_lag_max_records{client_id="listener-1",} -Inf
1条答案
按热度按时间3j86kqsm1#
你说“不行”是什么意思?我刚测试过,效果很好。。。
编辑2
我真的看到了
-Infinity
在mbean中,如果事务超时,也就是说,如果监听器在我的测试中没有在60秒内退出。