(rocketmq) branch develop updated: [ISSUE #9284] When pullMessage overflow one, should refresh recordDiskFallBehind data (#9285)

[lizhimin]

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

lizhimin 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 830e89eed1 [ISSUE #9284] When pullMessage overflow one, should refresh 
recordDiskFallBehind data (#9285)
830e89eed1 is described below

commit 830e89eed12b6a24c157db1d021989c409d2e2e5
Author: ymwneu <ymw...@126.com>
AuthorDate: Tue Apr 1 13:52:26 2025 +0800

    [ISSUE #9284] When pullMessage overflow one, should refresh 
recordDiskFallBehind data (#9285)
---
 .../main/java/org/apache/rocketmq/store/DefaultMessageStore.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index f8caf7beac..13af812c3f 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -966,6 +966,12 @@ public class DefaultMessageStore implements MessageStore {
         } else {
             this.storeStatsService.getGetMessageTimesTotalMiss().add(1);
         }
+
+        if (this.messageStoreConfig.isDiskFallRecorded() && 
GetMessageStatus.OFFSET_OVERFLOW_ONE == status) {
+            brokerStatsManager.recordDiskFallBehindSize(group, topic, queueId, 
0);
+            brokerStatsManager.recordDiskFallBehindTime(group, topic, queueId, 
0);
+        }
+
         long elapsedTime = this.getSystemClock().now() - beginTime;
         this.storeStatsService.setGetMessageEntireTimeMax(elapsedTime);