[ISSUE #7334] registerIncrementBrokerData for single topic update

Signed-off-by: Ziy1-Tan <[email protected]>
apache · Sep 11, 2023 · 5195450 · 5195450
1 parent 6fd0073
commit 5195450
Showing 1 changed file with 25 additions and 5 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -290,7 +290,11 @@ public TopicConfig createTopicInSendMessageMethod(final String topic, final Stri
         }
 
         if (createNew) {
-            this.brokerController.registerBrokerAll(false, true, true);
+            if (brokerController.getBrokerConfig().isEnableSingleTopicRegister()) {
+                this.brokerController.registerSingleTopicAll(topicConfig);
+            } else {
+                this.brokerController.registerIncrementBrokerData(topicConfig, dataVersion);
+            }
         }
 
         return topicConfig;
@@ -394,7 +398,11 @@ public TopicConfig createTopicInSendMessageBackMethod(
         }
 
         if (createNew) {
-            this.brokerController.registerBrokerAll(false, true, true);
+            if (brokerController.getBrokerConfig().isEnableSingleTopicRegister()) {
+                this.brokerController.registerSingleTopicAll(topicConfig);
+            } else {
+                this.brokerController.registerIncrementBrokerData(topicConfig, dataVersion);
+            }
         }
 
         return topicConfig;
@@ -435,7 +443,11 @@ public TopicConfig createTopicOfTranCheckMaxTime(final int clientDefaultTopicQue
         }
 
         if (createNew) {
-            this.brokerController.registerBrokerAll(false, true, true);
+            if (brokerController.getBrokerConfig().isEnableSingleTopicRegister()) {
+                this.brokerController.registerSingleTopicAll(topicConfig);
+            } else {
+                this.brokerController.registerIncrementBrokerData(topicConfig, dataVersion);
+            }
         }
 
         return topicConfig;
@@ -461,7 +473,11 @@ public void updateTopicUnitFlag(final String topic, final boolean unit) {
             dataVersion.nextVersion(stateMachineVersion);
 
             this.persist();
-            this.brokerController.registerBrokerAll(false, true, true);
+            if (brokerController.getBrokerConfig().isEnableSingleTopicRegister()) {
+                this.brokerController.registerSingleTopicAll(topicConfig);
+            } else {
+                this.brokerController.registerIncrementBrokerData(topicConfig, dataVersion);
+            }
         }
     }
 
@@ -484,7 +500,11 @@ public void updateTopicUnitSubFlag(final String topic, final boolean hasUnitSub)
             dataVersion.nextVersion(stateMachineVersion);
 
             this.persist();
-            this.brokerController.registerBrokerAll(false, true, true);
+            if (brokerController.getBrokerConfig().isEnableSingleTopicRegister()) {
+                this.brokerController.registerSingleTopicAll(topicConfig);
+            } else {
+                this.brokerController.registerIncrementBrokerData(topicConfig, dataVersion);
+            }
         }
     }