From 9b4f16a5b45fe740eead6e67781b796efd869be8 Mon Sep 17 00:00:00 2001
From: fujian-zfj <2573259572@qq.com>
Date: Mon, 18 Mar 2024 14:08:35 +0800
Subject: [PATCH] [ISSUE #7914] Fix the issue that pop revive msg to retry
 topic may lose messages  (#7915)

* typo int readme[ecosystem]

* fix pop problem
---
 .../apache/rocketmq/broker/processor/PopReviveService.java   | 5 -----
 1 file changed, 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
index 104b78d441..4fab3d500b 100644
--- 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 @@ 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);
                 });