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")