rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From huzongt...@apache.org
Subject [rocketmq] branch develop updated: [ISSUE #3177]updateAclConfig in all brokers. (#3184)
Date Fri, 30 Jul 2021 05:42:10 GMT
This is an automated email from the ASF dual-hosted git repository.

huzongtang 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 17b9efe  [ISSUE #3177]updateAclConfig in all brokers. (#3184)
17b9efe is described below

commit 17b9efe16d8c39c5c1c60199de8d44dcaad2348d
Author: zhangjidi2016 <1017543663@qq.com>
AuthorDate: Fri Jul 30 13:41:52 2021 +0800

    [ISSUE #3177]updateAclConfig in all brokers. (#3184)
    
    Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
---
 .../rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java
b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java
index b625cd9..465a2db 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateAccessConfigSubCommand.java
@@ -164,9 +164,9 @@ public class UpdateAccessConfigSubCommand implements SubCommand {
                 String clusterName = commandLine.getOptionValue('c').trim();
 
                 defaultMQAdminExt.start();
-                Set<String> masterSet =
-                    CommandUtil.fetchMasterAddrByClusterName(defaultMQAdminExt, clusterName);
-                for (String addr : masterSet) {
+                Set<String> brokerAddrSet =
+                    CommandUtil.fetchMasterAndSlaveAddrByClusterName(defaultMQAdminExt, clusterName);
+                for (String addr : brokerAddrSet) {
                     defaultMQAdminExt.createAndUpdatePlainAccessConfig(addr, accessConfig);
                     System.out.printf("create or update plain access config to %s success.%n",
addr);
                 }

Mime
View raw message