File tree Expand file tree Collapse file tree
broker/src/main/java/org/apache/rocketmq/broker/slave Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -93,9 +93,9 @@ private void syncTopicConfig() {
9393 while (iterator .hasNext ()) {
9494 Map .Entry <String , TopicConfig > entry = iterator .next ();
9595 if (!newTopicConfigTable .containsKey (entry .getKey ())) {
96- iterator .remove ();
96+ iterator .remove ();
97+ topicConfigManager .deleteTopicConfig (entry .getKey ());
9798 }
98- topicConfigManager .deleteTopicConfig (entry .getKey ());
9999 }
100100
101101 //update
@@ -188,9 +188,9 @@ private void syncSubscriptionGroupConfig() {
188188 while (iterator .hasNext ()) {
189189 Map .Entry <String , SubscriptionGroupConfig > configEntry = iterator .next ();
190190 if (!newSubscriptionGroupTable .containsKey (configEntry .getKey ())) {
191- iterator .remove ();
191+ iterator .remove ();
192+ subscriptionGroupManager .deleteSubscriptionGroupConfig (configEntry .getKey ());
192193 }
193- subscriptionGroupManager .deleteSubscriptionGroupConfig (configEntry .getKey ());
194194 }
195195 // update
196196 newSubscriptionGroupTable .values ().forEach (subscriptionGroupManager ::putSubscriptionGroupConfig );
You can’t perform that action at this time.
0 commit comments