From 9d8a8347af6d6afcea93d6a658b7d378942f1dd1 Mon Sep 17 00:00:00 2001
From: mipengcheng3 <mipengcheng3@jd.com>
Date: Mon, 25 Dec 2023 09:58:02 +0800
Subject: [PATCH] when meeting END_OF_FILE, other exceptions should be
 validated too.

---
 .../main/java/org/apache/rocketmq/store/CommitLog.java    | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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;