From 58983991273de7afcf28a843ca6f973df80d5c36 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=84=E5=A3=B0?= Date: Fri, 31 Aug 2018 16:13:16 +0800 Subject: [PATCH] Modify commandLine getOption --- .../rocketmq/tools/command/message/ConsumeMessageCommand.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git 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 index 6bf91840..8aed59ea 100644 --- 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); } -- GitLab