从jmx获取kafka日志结束偏移量

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

我正在尝试构建一个实时监控解决方案,它将覆盖n个kafka集群。我要做的一件事就是用内部函数来计算滞后 __consumer_offsets 主题和主题 kafka.log:type=Log,name=LogEndOffset 姆拜恩。
我很好奇的是,假设我的kafka集群中有5个代理,我需要从每个代理收集logendoffset并进行max来获得logendoffset,还是只从一个代理获取就足够了?
一个附带的问题,如果我在对数偏移上做一分钟,那会给我一个高水位线吗?

whlutmcx

whlutmcx1#

从jmx exporter,您可以使用以下查询:

sum(max(kafka_log_logendoffset{topic="your_topic_name"}) by (topic,partition))

相关问题