(rocketmq) branch develop updated: Fix revive lag metric calculation (#8652)

[lollipop]

This is an automated email from the ASF dual-hosted git repository.

lollipop pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d59a2ddb37 Fix revive lag metric calculation (#8652)
d59a2ddb37 is described below

commit d59a2ddb37e62ca09a6a6e3f5086a96d6972a041
Author: Liu Shengzhong <szliu0...@gmail.com>
AuthorDate: Tue May 13 13:27:16 2025 +0800

    Fix revive lag metric calculation (#8652)
    
    Fix revive lag metric calculation (#8652)
---
 .../java/org/apache/rocketmq/broker/processor/PopReviveService.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
index e1ead86169..2be41a69d6 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
@@ -620,7 +620,8 @@ public class PopReviveService extends ServiceThread {
         if (currentReviveMessageTimestamp <= 0) {
             return 0;
         }
-        long diff = 
brokerController.getMessageStore().getMaxOffsetInQueue(reviveTopic, queueId) - 
reviveOffset;
+        // the next pull offset is reviveOffset + 1
+        long diff = 
brokerController.getMessageStore().getMaxOffsetInQueue(reviveTopic, queueId) - 
reviveOffset - 1;
         return Math.max(0, diff);
     }