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 6bf91840aeb48df6e9b9a093201d06c7732b1bfd..8aed59ea449066d048f05081e924484a5421c71f 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);
             }