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 ecbe1f38a54def3368ec02e2f1893f516e29f73d..5038123561bf0aafb880ee0100d3e3323c2c49ae 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 14cd720615bceb56e624fc69b901f0cccde4df22..404d90d669212cc610530e87e1a23d0fd06164b0 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);