(rocketmq) branch develop updated: [ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954)

[lizhimin]

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

lizhimin 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 9fecafe086 [ISSUE #9953] Fix: there's no need to decompress message 
body in server side (#9954)
9fecafe086 is described below

commit 9fecafe086f614b3559ae77e6a0257506a9d974e
Author: Humkum <1109939...@qq.com>
AuthorDate: Mon Jan 12 11:26:58 2026 +0800

    [ISSUE #9953] Fix: there's no need to decompress message body in server 
side (#9954)
---
 .../java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 4361431bec..ea262bb25d 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -2853,7 +2853,7 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
             MessageId messageId = 
MessageDecoder.decodeMessageId(requestHeader.getMsgId());
             selectMappedBufferResult = this.brokerController.getMessageStore()
                 .selectOneMessageByOffset(messageId.getOffset());
-            MessageExt msg = 
MessageDecoder.decode(selectMappedBufferResult.getByteBuffer());
+            MessageExt msg = 
MessageDecoder.decode(selectMappedBufferResult.getByteBuffer(), true, false);
             msg.putUserProperty(MessageConst.PROPERTY_TRANSACTION_CHECK_TIMES, 
String.valueOf(0));
             PutMessageResult putMessageResult = 
this.brokerController.getMessageStore()
                 .putMessage(toMessageExtBrokerInner(msg));