From fbff64b31de7e3a2690c5c06f05d7759a54d0a0f Mon Sep 17 00:00:00 2001 From: dingshuangxi888 Date: Tue, 14 Oct 2025 10:43:12 +0800 Subject: [PATCH] Fix time dequeue latency unit to milliseconds. Change-Id: I52e1f5c643f095b04b73c362c93dbde920250cc2 --- .../rocketmq/store/metrics/DefaultStoreMetricsManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java b/store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java index 6f2bc322542..ed90bc40f51 100644 --- a/store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java +++ b/store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java @@ -185,7 +185,7 @@ public void init(Meter meter, Supplier attributesBuilderSuppl .ofLongs() .buildWithCallback(measurement -> { TimerMessageStore timerMessageStore = messageStore.getTimerMessageStore(); - measurement.record(timerMessageStore.getDequeueBehind(), this.newAttributesBuilder().build()); + measurement.record(timerMessageStore.getDequeueBehindMillis(), this.newAttributesBuilder().build()); }); this.timingMessages = meter.gaugeBuilder(GAUGE_TIMING_MESSAGES) .setDescription("Current message number in timing")