[ISSUE apache#8609] Add the BrokerConfig updateNameServerAddrPeriod (a…

…pache#8626)
yx9o · Sep 4, 2024 · 5d43e7d · 5d43e7d
1 parent 632943e
commit 5d43e7d
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -747,7 +747,7 @@ public void run() {
                         LOG.error("Failed to update nameServer address list", e);
                     }
                 }
-            }, 1000 * 10, 1000 * 60 * 2, TimeUnit.MILLISECONDS);
+            }, 1000 * 10, this.brokerConfig.getUpdateNameServerAddrPeriod(), TimeUnit.MILLISECONDS);
         } else if (this.brokerConfig.isFetchNamesrvAddrByAddressServer()) {
             this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
 

diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
@@ -185,6 +185,11 @@ public class BrokerConfig extends BrokerIdentity {
      */
     private int registerNameServerPeriod = 1000 * 30;
 
+    /**
+     * This configurable item defines interval of update name server address. Default: 120 * 1000 milliseconds
+     */
+    private int updateNameServerAddrPeriod = 1000 * 120;
+
     /**
      * the interval to send heartbeat to name server for liveness detection.
      */
@@ -1837,4 +1842,12 @@ public boolean isSkipWhenCKRePutReachMaxTimes() {
     public void setSkipWhenCKRePutReachMaxTimes(boolean skipWhenCKRePutReachMaxTimes) {
         this.skipWhenCKRePutReachMaxTimes = skipWhenCKRePutReachMaxTimes;
     }
+
+    public int getUpdateNameServerAddrPeriod() {
+        return updateNameServerAddrPeriod;
+    }
+
+    public void setUpdateNameServerAddrPeriod(int updateNameServerAddrPeriod) {
+        this.updateNameServerAddrPeriod = updateNameServerAddrPeriod;
+    }
 }