Modify commandLine getOption

58983991 · 射声 · 37a642cc · 58983991
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java ...rocketmq/tools/command/message/ConsumeMessageCommand.java +1 -1

未找到文件。
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java
@@ -131,7 +131,7 @@ public class ConsumeMessageCommand implements SubCommand {
        try {
            /* Group name must be set before consumer start */
            if (commandLine.hasOption('g')) {
-                String consumerGroup = commandLine.getOptionValue('b').trim();
+                String consumerGroup = commandLine.getOptionValue('g').trim();
                defaultMQPullConsumer.setConsumerGroup(consumerGroup);
            }