diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index fcb9024e589e..6ea7846f856b 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1197,7 +1197,13 @@ public CompletableFuture<PutMessageResult> asyncPutMessages(final MessageExtBatc
                             setFileReadMode(mappedFile, LibC.MADV_RANDOM);
                         }
                         result = mappedFile.appendMessages(messageExtBatch, this.appendMessageCallback, putMessageContext);
-                        break;
+                        CompletableFuture<PutMessageResult> validateAppendMessageResult = validateAppendMessageResult(result);
+                        if (null == validateAppendMessageResult) {
+                            break;
+                        } else {
+                            beginTimeInLock = 0;
+                            return validateAppendMessageResult;
+                        }
                     case MESSAGE_SIZE_EXCEEDED:
                     case PROPERTIES_SIZE_EXCEEDED:
                         beginTimeInLock = 0;