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 <[email protected]>
AuthorDate: Fri Jul 30 13:41:52 2021 +0800

    [ISSUE #3177]updateAclConfig in all brokers. (#3184)
    
    Co-authored-by: zhangjidi2016 <[email protected]>
---
 .../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);
                 }

Reply via email to