From 5fb1d49063693a1ea7f8cc74506052a37c749cbd Mon Sep 17 00:00:00 2001 From: fuchong Date: Thu, 6 Aug 2026 10:53:25 +0800 Subject: [PATCH 1/2] [ISSUE #10819] Correct misleading CommitLog buffer comment --- store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +- 1 file changed, 1 insertion(+), 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 260f021aed7..1445968715f 100644 --- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java @@ -2092,7 +2092,7 @@ public AppendMessageResult doAppend(final long fileFromOffset, final ByteBuffer final long beginTimeMills = CommitLog.this.defaultMessageStore.now(); CommitLog.this.getMessageStore().getPerfCounter().startTick("WRITE_MEMORY_TIME_MS"); - // Write messages to the queue buffer + // Copy the encoded message into the current CommitLog write buffer byteBuffer.put(preEncodeBuffer); CommitLog.this.getMessageStore().getPerfCounter().endTick("WRITE_MEMORY_TIME_MS"); msgInner.setEncodedBuff(null); From 0724d74128a9990696324ae8f817f07f4e52be00 Mon Sep 17 00:00:00 2001 From: fuchong Date: Thu, 6 Aug 2026 10:59:49 +0800 Subject: [PATCH 2/2] [ISSUE #10819] Refine CommitLog comment wording --- store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +- 1 file changed, 1 insertion(+), 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 1445968715f..f4eec36853d 100644 --- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java @@ -2092,7 +2092,7 @@ public AppendMessageResult doAppend(final long fileFromOffset, final ByteBuffer final long beginTimeMills = CommitLog.this.defaultMessageStore.now(); CommitLog.this.getMessageStore().getPerfCounter().startTick("WRITE_MEMORY_TIME_MS"); - // Copy the encoded message into the current CommitLog write buffer + // Append the encoded message to the current CommitLog buffer byteBuffer.put(preEncodeBuffer); CommitLog.this.getMessageStore().getPerfCounter().endTick("WRITE_MEMORY_TIME_MS"); msgInner.setEncodedBuff(null);