(rocketmq) branch develop updated: [ISSUE #10968] Copy transaction message properties directly instead of encode/decode roundtrip (#10970)

[jinrongtong]

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

RongtongJin 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 50258ab2c9 [ISSUE #10968] Copy transaction message properties directly 
instead of encode/decode roundtrip (#10970)
50258ab2c9 is described below

commit 50258ab2c98e0fd0e8b3783d977f83444ce53836
Author: Jiahua Wang <90542846+wang-jia...@users.noreply.github.com>
AuthorDate: Thu Sep 3 14:50:31 2026 +0800

    [ISSUE #10968] Copy transaction message properties directly instead of 
encode/decode roundtrip (#10970)
    
    Co-authored-by: wangjiahua.wjh <wangjiahua....@alibaba-inc.com>
---
 .../org/apache/rocketmq/broker/processor/EndTransactionProcessor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
index 2be2e18802..a792f80456 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
@@ -288,7 +288,7 @@ public class EndTransactionProcessor implements 
NettyRequestProcessor {
                 
msgExt.putUserProperty(MessageConst.PROPERTY_TRANSACTION_CHECK_TIMES, 
String.valueOf(checkTimesRocksDB));
             }
         }
-        MessageAccessor.setProperties(msgInner, 
MessageDecoder.string2messageProperties(MessageDecoder.messageProperties2String(msgExt.getProperties())));
+        MessageAccessor.setProperties(msgInner, 
MessageAccessor.deepCopyProperties(msgExt.getProperties()));
         MessageAccessor.clearProperty(msgInner, 
MessageConst.PROPERTY_REAL_TOPIC);
         MessageAccessor.clearProperty(msgInner, 
MessageConst.PROPERTY_REAL_QUEUE_ID);
         
msgInner.setPropertiesString(MessageDecoder.messageProperties2String(msgInner.getProperties()));