Kafka Streams全局存储指标：如何通过标准指标检测消费者滞后

确实，Global Store的内部消费者不属于用户可见的消费组，没法用标准Consumer API的消费组滞后指标直接监控，但Kafka Streams本身提供了专门针对Global Store的内置监控指标，不需要自己写自定义逻辑：

• 分区滞后指标：kafka.streams:type=global-store-metrics,scope={store-name},name=partition-lag
  这个指标按分区维度统计Global Store消费者当前处理偏移量与对应分区最新偏移量的差值，直接反映每个分区的滞后情况。
• 记录处理速率指标：kafka.streams:type=global-store-metrics,scope={store-name},name=record-process-rate
  结合滞后指标来看，如果速率稳定且滞后持续降低或维持低位，说明Global Store在正常更新；如果速率为0且滞后增大，大概率是出现了异常。

这些指标可以通过JMX直接查看，也能通过Kafka Prometheus exporter抓取后接入监控系统，都是Kafka Streams官方支持的标准监控方式，无需额外编码。

如果你的版本里找不到上述指标，建议检查Kafka Streams版本（0.11.0.0及以上版本开始支持Global Store相关监控指标），同时确认是否在配置中开启了JMX监控（默认是开启状态）。

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