[ISSUE apache#7914] Fix the issue that pop revive msg to retry topic …

…may lose messages (apache#7915) * typo int readme[ecosystem] * fix pop problem
Oliverwqcwrw · Mar 18, 2024 · 9b4f16a · 9b4f16a
1 parent e1339ac
commit 9b4f16a
Showing 1 changed file with 0 additions and 5 deletions.
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
@@ -541,11 +541,6 @@ private void reviveMsgFromCk(PopCheckPoint popCheckPoint) {
 
                         }
                     }
-                    //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);
                 });