PromQL中如何获取Kafka延迟指标的正确值及对应时间戳

要获取指定Kafka Topic消费组延迟指标在1年范围内的最大值及其原始时间戳，你可以使用以下PromQL查询：

sort_desc(max by () (kafka_consumergroup_group_lag_seconds{topic=~"TOPIC_PLACEHOLDER"}[1y:10s]))[0]

为什么原方法时间戳不对？ #

你之前用的max(max_over_time(...))存在时间戳丢失的问题：

1. max_over_time会将每个消费组的延迟时间序列（范围向量）转换为即时向量——值为该组的历史最大值，但时间戳会被替换为查询执行的当前时间。
2. 外层的max只是对这些即时向量的值取全局最大，最终结果的时间戳依然是查询时间，而非原始数据点的时间。

新查询的逻辑 #

1. max by () (范围向量)：对每个时间点的所有消费组延迟值取全局最大，生成一个仅包含全局最大值的新范围向量，这个向量完整保留了每个数据点的原始时间戳。
2. sort_desc(...)：将这个新范围向量按值从大到小排序。
3. [0]：取排序后的第一个元素，也就是整个时间范围内的最大延迟值及其对应的原始时间戳。

按消费组单独取最大值的场景 #

如果你的需求是获取每个消费组自己的历史最大值及对应时间戳，直接使用以下查询即可：

sort_desc(kafka_consumergroup_group_lag_seconds{topic=~"TOPIC_PLACEHOLDER"}[1y:10s])[0]

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