(rocketmq) branch develop updated: [ISSUE #9723] Fix missing "+" symbol in metadata updates for v2 configuration (#9724)

[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 a4da5f5794 [ISSUE #9723] Fix missing "+" symbol in metadata updates 
for v2 configuration (#9724)
a4da5f5794 is described below

commit a4da5f5794e7f3e6b0828f2d2655896ae707b1a6
Author: cvictory <shenglic...@gmail.com>
AuthorDate: Mon Sep 22 10:16:41 2025 +0800

    [ISSUE #9723] Fix missing "+" symbol in metadata updates for v2 
configuration (#9724)
    
    Co-authored-by: cvictory <shengli.ca...@alibaba-inc.com>
---
 .../apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java
index dd67871f18..1deb6d29b9 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java
@@ -132,6 +132,7 @@ public class SubscriptionGroupManagerV2 extends 
SubscriptionGroupManager {
         if (config == null || MixAll.isLmq(config.getGroupName())) {
             return;
         }
+        super.updateSubscriptionGroupConfigWithoutPersist(config);
         ByteBuf keyBuf = ConfigHelper.keyBufOf(TableId.SUBSCRIPTION_GROUP, 
config.getGroupName());
         ByteBuf valueBuf = ConfigHelper.valueBufOf(config, 
SerializationType.JSON);
         try (WriteBatch writeBatch = new WriteBatch()) {
@@ -147,7 +148,6 @@ public class SubscriptionGroupManagerV2 extends 
SubscriptionGroupManager {
             keyBuf.release();
             valueBuf.release();
         }
-        super.updateSubscriptionGroupConfigWithoutPersist(config);
     }
 
     @Override