opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #7914] Fix the issue that pop revive msg to retry topic may lose messages (#7915)

Browse Source 
* typo int readme[ecosystem]

* fix pop problem
This commit is contained in:
fujian-zfj
2024-03-18 14:08:35 +08:00
committed by GitHub
parent e1339ac8a0
commit 9b4f16a5b4
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
-5
View File
@@ -541,11 +541,6 @@ public class PopReviveService extends ServiceThread {
}
}
//skip ck from last epoch
if (popCheckPoint.getPopTime() < message.getStoreTimestamp()) {
POP_LOGGER.warn("reviveQueueId={}, skip ck from last epoch {}", queueId, popCheckPoint);
return new Pair<>(msgOffset, true);
}
boolean result = reviveRetry(popCheckPoint, message);
return new Pair<>(msgOffset, result);
});