opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-25 10:03:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9284] When pullMessage overflow one, should refresh recordDiskFallBehind data (#9285)

Browse Source
This commit is contained in:
ymwneu
2025-07-19 18:17:56 +08:00
committed by RongtongJin
parent e9dc679d83
commit 3c679716b6
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+6
View File
@@ -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);