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);
}