关于Apache Kafka MirrorMaker2核心监控指标的技术咨询

关于 record-count 指标 #

• 是否为每个主题分区持续增长的计数？
  是的，record-count 是按主题分区维度持续累加的计数器，统计的是从源集群成功复制到目标集群的消息总数量。除非MirrorMaker2进程重启，否则这个数值只会递增，不会重置。
• 指标输出频率及配置支持？
  这个指标的输出频率由Kafka Connect的metrics采样配置控制，默认是每分钟（60秒）输出一次。你可以通过以下两个参数调整频率：
  • metrics.sample.window.ms：指定指标采样的时间窗口大小（默认30000毫秒，即30秒）
  • metrics.num.samples：指定采样窗口内的样本数量（默认2）
    比如如果把metrics.sample.window.ms设为15000、metrics.num.samples设为1，就会每15秒输出一次指标数据。

关于 replication-latency-ms 指标 #

• 指标输出频率及配置支持？
  和record-count一样，这个延迟指标的输出频率同样受Kafka Connect的metrics.sample.window.ms和metrics.num.samples参数控制，默认每分钟输出一次。需要注意的是，replication-latency-ms是采样窗口内的平均延迟值，调整采样频率会直接影响延迟数据的粒度——窗口越小、频率越高，延迟数据的实时性越强，但也会增加metrics的输出量。

内容的提问来源于stack exchange，提问作者Tushar