diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java index 0a1a4b238248dd52efbaae93b008a92f414b0a91..d82453dc9ff72d031dcbb2fcbc561da9b27fe9bb 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java @@ -76,7 +76,7 @@ public class DeleteAccessConfigSubCommand implements SubCommand { defaultMQAdminExt.start(); defaultMQAdminExt.deletePlainAccessConfig(addr, accessKey); - System.out.printf("delete plain access config account to %s success.%n", addr); + System.out.printf("delete plain access config account from %s success.%n", addr); System.out.printf("account's accesskey is:%s", accessKey); return; @@ -89,7 +89,7 @@ public class DeleteAccessConfigSubCommand implements SubCommand { CommandUtil.fetchMasterAddrByClusterName(defaultMQAdminExt, clusterName); for (String addr : masterSet) { defaultMQAdminExt.deletePlainAccessConfig(addr, accessKey); - System.out.printf("delete plain access config account to %s success.%n", addr); + System.out.printf("delete plain access config account from %s success.%n", addr); } System.out.printf("account's accesskey is:%s", accessKey); 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 10241bf91e1970afd04c46b568cf6d4e645fbb52..b625cd94c18c89bf048d98c45da926d17905e634 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 @@ -50,7 +50,7 @@ public class UpdateAccessConfigSubCommand implements SubCommand { Option opt = new Option("b", "brokerAddr", true, "update acl config file to which broker"); optionGroup.addOption(opt); - opt = new Option("c", "clusterName", true, "update cl config file to which cluster"); + opt = new Option("c", "clusterName", true, "update acl config file to which cluster"); optionGroup.addOption(opt); optionGroup.setRequired(true);