PromQL的increase()函数计算结果与实际增量不符问题排查

背景 #

使用Spring Boot开发Kafka消费者，通过Spring内置的MeterRegistry结合Prometheus、Grafana实现监控，指标存储于VictoriaMetrics。用于统计消费事件总数的指标为kafka_consumer_fetch_manager_records_consumed_total，计划使用的查询语句为：

sum(increase(kafka_consumer_fetch_manager_records_consumed_total [$__range])) by (topic)

问题 #

重启消费者后，该指标未重置为0而是从40开始累计，最终达到192，但使用increase()函数计算得到的结果为152，与预期值不符，请求协助排查原因。

补充说明 #

已尝试使用查询语句：

increase(sum(kafka_consumer_fetch_manager_records_consumed_total) by (namespace) [$__range])

该语句结果正确，但不符合监控查询的最佳实践。以下是注册Kafka指标的代码：

DefaultKafkaConsumerFactory<String, Map<String, String>> defaultKafkaConsumerFactory = new DefaultKafkaConsumerFactory<>(config, new StringDeserializer(),
                new ErrorHandlingDeserializer<>(new JsonDeserializer<>(Map.class)));

defaultKafkaConsumerFactory.addListener(new MicrometerConsumerListener<>(@Autowired MeterRegistry));

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