Nov 14, 2025
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
                            return new DispatchRequest(-1, false/* success */);
                        }
                    } else {
                        // Read full message for logging when error occurs
                        ByteBuffer fullMessageBuffer = byteBuffer.duplicate();
                        int messageStartPos = fullMessageBuffer.position() - totalSize;
                        fullMessageBuffer.position(messageStartPos);
                        fullMessageBuffer.limit(messageStartPos + totalSize);
                        byte[] fullMessageBytes = new byte[totalSize];
                        fullMessageBuffer.get(fullMessageBytes, 0, totalSize);

                        // Print full message and especially properties
                        log.warn(
                            "CommitLog#checkAndDispatchMessage: failed to check message CRC, not found CRC in properties");
                            "CommitLog#checkAndDispatchMessage: failed to check message CRC, not found CRC in properties. topic={}, properties={}, propertiesLength={}, fullMessageHex={}",
                            topic, propertiesMap != null ? propertiesMap.toString() : "null", propertiesLength, UtilAll.bytes2string(fullMessageBytes));
                        return new DispatchRequest(-1, false/* success */);
                    }
                }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -618,8 +618,18 @@ public DispatchRequest checkMessageAndReturnSize(java.nio.ByteBuffer byteBuffer,
		return new DispatchRequest(-1, false/* success */);
		}
		} else {
		// Read full message for logging when error occurs
		ByteBuffer fullMessageBuffer = byteBuffer.duplicate();
		int messageStartPos = fullMessageBuffer.position() - totalSize;
		fullMessageBuffer.position(messageStartPos);
		fullMessageBuffer.limit(messageStartPos + totalSize);
		byte[] fullMessageBytes = new byte[totalSize];
		fullMessageBuffer.get(fullMessageBytes, 0, totalSize);

		// Print full message and especially properties
		log.warn(
		"CommitLog#checkAndDispatchMessage: failed to check message CRC, not found CRC in properties");
		"CommitLog#checkAndDispatchMessage: failed to check message CRC, not found CRC in properties. topic={}, properties={}, propertiesLength={}, fullMessageHex={}",
		topic, propertiesMap != null ? propertiesMap.toString() : "null", propertiesLength, UtilAll.bytes2string(fullMessageBytes));
		return new DispatchRequest(-1, false/* success */);
		}
		}
Expand Down