fix: slave delete all topic config and subGroup config when sync config from master

humkum · humkum · commit 5cc910de40db · 2026-01-08T11:32:15.000+08:00
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
@@ -95,7 +95,6 @@ private void syncTopicConfig() {
                         if (!newTopicConfigTable.containsKey(entry.getKey())) {
                             iterator.remove();
                         }
-                        topicConfigManager.deleteTopicConfig(entry.getKey());
                     }
 
                     //update
@@ -190,7 +189,6 @@ private void syncSubscriptionGroupConfig() {
                         if (!newSubscriptionGroupTable.containsKey(configEntry.getKey())) {
                             iterator.remove();
                         }
-                        subscriptionGroupManager.deleteSubscriptionGroupConfig(configEntry.getKey());
                     }
                     // update
                     newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::putSubscriptionGroupConfig);

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,6 @@ private void syncTopicConfig() {`
`95`	`95`	`if (!newTopicConfigTable.containsKey(entry.getKey())) {`
`96`	`96`	`iterator.remove();`
`97`	`97`	`}`
`98`		`- topicConfigManager.deleteTopicConfig(entry.getKey());`
`99`	`98`	`}`
`100`	`99`
`101`	`100`	`//update`
`@@ -190,7 +189,6 @@ private void syncSubscriptionGroupConfig() {`
`190`	`189`	`if (!newSubscriptionGroupTable.containsKey(configEntry.getKey())) {`
`191`	`190`	`iterator.remove();`
`192`	`191`	`}`
`193`		`- subscriptionGroupManager.deleteSubscriptionGroupConfig(configEntry.getKey());`
`194`	`192`	`}`
`195`	`193`	`// update`
`196`	`194`	`newSubscriptionGroupTable.values().forEach(subscriptionGroupManager::putSubscriptionGroupConfig);`