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