opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +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-04-01 13:52:26 +08:00
committed by GitHub
parent b5ab93ce7d
commit 830e89eed1
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);