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); });