(rocketmq) branch develop updated: [ISSUE #8350] Properties store error: crc32ReservedLength make undefine memory in properties when no enable AppendPropCRC (#8351)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 259efdb086 [ISSUE #8350] Properties store error: crc32ReservedLength 
make undefine memory in properties when no enable AppendPropCRC (#8351)
259efdb086 is described below

commit 259efdb08691614ecdca201b7ecb20bfc15f6f15
Author: Dongyuan Pan <dongyuanp...@gmail.com>
AuthorDate: Tue Jul 16 17:24:14 2024 +0800

    [ISSUE #8350] Properties store error: crc32ReservedLength make undefine 
memory in properties when no enable AppendPropCRC (#8351)
---
 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 c2150d7a32..1dd60523a5 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1834,7 +1834,7 @@ public class CommitLog implements Swappable {
         private static final int END_FILE_MIN_BLANK_LENGTH = 4 + 4;
         // Store the message content
         private final ByteBuffer msgStoreItemMemory;
-        private final int crc32ReservedLength = CommitLog.CRC32_RESERVED_LEN;
+        private final int crc32ReservedLength = enabledAppendPropCRC ? 
CommitLog.CRC32_RESERVED_LEN : 0;
         private final MessageStoreConfig messageStoreConfig;
 
         DefaultAppendMessageCallback(MessageStoreConfig messageStoreConfig) {