File tree Expand file tree Collapse file tree
broker/src/main/java/org/apache/rocketmq/broker/config/v2 Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -132,6 +132,7 @@ public void updateSubscriptionGroupConfig(final SubscriptionGroupConfig config)
132132 if (config == null || MixAll .isLmq (config .getGroupName ())) {
133133 return ;
134134 }
135+ super .updateSubscriptionGroupConfigWithoutPersist (config );
135136 ByteBuf keyBuf = ConfigHelper .keyBufOf (TableId .SUBSCRIPTION_GROUP , config .getGroupName ());
136137 ByteBuf valueBuf = ConfigHelper .valueBufOf (config , SerializationType .JSON );
137138 try (WriteBatch writeBatch = new WriteBatch ()) {
@@ -147,7 +148,6 @@ public void updateSubscriptionGroupConfig(final SubscriptionGroupConfig config)
147148 keyBuf .release ();
148149 valueBuf .release ();
149150 }
150- super .updateSubscriptionGroupConfigWithoutPersist (config );
151151 }
152152
153153 @ Override
You can’t perform that action at this time.
0 commit comments