diff --git a/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java b/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
index d1a36c9e136..fe7af222e2c 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
@@ -612,8 +612,8 @@ public void correctMinOffset(long minCommitLogOffset) {
             }
 
             try {
-                // No valid consume entries
-                if (result.getSize() == 0) {
+                // No valid consume entries or incomplete record
+                if (result.getSize() < ConsumeQueue.CQ_STORE_UNIT_SIZE) {
                     log.debug("ConsumeQueue[topic={}, queue-id={}] contains no valid entries", topic, queueId);
                     return;
                 }