You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2024/09/04 09:14:50 UTC
(rocketmq) branch develop updated: [ISSUE #8609] Add the BrokerConfig updateNameServerAddrPeriod (#8626)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 5d43e7d111 [ISSUE #8609] Add the BrokerConfig updateNameServerAddrPeriod (#8626)
5d43e7d111 is described below
commit 5d43e7d111ab2461c94fc62c1021cf7aee9d0219
Author: qianye <37...@users.noreply.github.com>
AuthorDate: Wed Sep 4 17:14:45 2024 +0800
[ISSUE #8609] Add the BrokerConfig updateNameServerAddrPeriod (#8626)
---
.../java/org/apache/rocketmq/broker/BrokerController.java | 2 +-
.../main/java/org/apache/rocketmq/common/BrokerConfig.java | 13 +++++++++++++
2 files changed, 14 insertions(+), 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
index 145a952230..22ac7fedf1 100644
--- 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 class BrokerController {
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
index 10bf7f76e8..26afe593a2 100644
--- 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 class BrokerConfig extends BrokerIdentity {
public void setSkipWhenCKRePutReachMaxTimes(boolean skipWhenCKRePutReachMaxTimes) {
this.skipWhenCKRePutReachMaxTimes = skipWhenCKRePutReachMaxTimes;
}
+
+ public int getUpdateNameServerAddrPeriod() {
+ return updateNameServerAddrPeriod;
+ }
+
+ public void setUpdateNameServerAddrPeriod(int updateNameServerAddrPeriod) {
+ this.updateNameServerAddrPeriod = updateNameServerAddrPeriod;
+ }
}