diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java index ecbe1f38a5..5038123561 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java @@ -53,7 +53,7 @@ public class CLusterSendMsgRTCommand implements SubCommand { @Override public Options buildCommandlineOptions(Options options) { - Option opt = new Option("a", "amout", true, "message amout | default 100"); + Option opt = new Option("a", "amount", true, "message amount | default 100"); opt.setRequired(false); options.addOption(opt); diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java index 14cd720615..404d90d669 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java @@ -49,7 +49,7 @@ public class CheckMsgSendRTCommand implements SubCommand { opt.setRequired(true); options.addOption(opt); - opt = new Option("a", "amout", true, "message amout | default 100"); + opt = new Option("a", "amount", true, "message amount | default 100"); opt.setRequired(false); options.addOption(opt);