This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 809bfe6cb8 [ISSUE #9682] Increase initial delay for scanning inactive
brokers to 5000 milliseconds (#9683)
809bfe6cb8 is described below
commit 809bfe6cb8be0c16eb47ce2db8ee63e0926a6214
Author: mxsm <[email protected]>
AuthorDate: Wed Sep 10 14:04:53 2025 +0800
[ISSUE #9682] Increase initial delay for scanning inactive brokers to 5000
milliseconds (#9683)
---
.../src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
index be327cffa5..bbe1a08e0f 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
@@ -115,7 +115,7 @@ public class NamesrvController {
private void startScheduleService() {
this.scanExecutorService.scheduleAtFixedRate(NamesrvController.this.routeInfoManager::scanNotActiveBroker,
- 5, this.namesrvConfig.getScanNotActiveBrokerInterval(),
TimeUnit.MILLISECONDS);
+ 5000, this.namesrvConfig.getScanNotActiveBrokerInterval(),
TimeUnit.MILLISECONDS);
this.scheduledExecutorService.scheduleAtFixedRate(NamesrvController.this.kvConfigManager::printAllPeriodically,
1, 10, TimeUnit.MINUTES);