Kafka消费滞后于jmx

lymnna71  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(335)

我试着监测Kafka0.10中一个消费群体的滞后。
我们的消费者正在跟踪他们在Kafka的补偿,而不是zookeper。这意味着我可以使用以下方法得到这些数字:

bin/kafka-consumer-groups.sh --bootstrap-server <broker> --describe --group <group-name>

这个很好用。然而,我的经纪人已经使用prometheusjmx导出器来收集一些统计数据。我已将jconsole连接到代理,但无法看到jmx中报告的数据与 kafka-consumer-groups.sh .
不管怎样,用jmx从kafka那里得到这些信息,而不需要任何额外的工具吗?

fquxozlt

fquxozlt1#

你可以找回属性 {topic}-{partition}.records-lag 公制单位 kafka.consumer:type=consumer-fetch-manager-metrics,client-id={client-id} 对于所有分区。这应该相当于 consumer-groups.sh

相关问题