You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2026/01/12 03:27:04 UTC
(rocketmq) branch develop updated: [ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954)
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 <11...@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));