You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

咨询Micrometer Kafka监听器每分钟消费事件数的计算方法

Kafka监听器每分钟消费事件数的PromQL计算

首先明确:spring_kafka_listener_seconds_count是累计计数型指标(Counter),数值会随消费事件增加持续递增(服务重启或指标重置时归零)。

拆解你使用的两个表达式:

  • increase(spring_kafka_listener_seconds_count[1m]) / 60
    increase的作用是计算1分钟窗口内指标的总增量,也就是这1分钟实际消费的事件总数。你除以60后,得到的是每秒平均消费数,而非目标的每分钟消费数——这就是两个表达式结果差异巨大的核心原因。

  • rate(spring_kafka_listener_seconds_count[1m]) * 60
    rate会计算指标的每秒平均增长率(即每秒消费的事件数),乘以60后就转换为每分钟平均消费数,这才是你需要的结果。

额外补充:如果你的指标是严格按分钟粒度统计的,直接用increase(spring_kafka_listener_seconds_count[1m])就能得到每分钟消费数,无需除以60。但实际监控场景中,rate更适合处理采样数据有波动的情况,能平滑短时间内的峰值/谷值,输出更稳定的平均速率。

内容的提问来源于stack exchange,提问作者Matrix12

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.24 18:02:39