diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
index b946ee141ebc507da3df465b9a9fa31c043790a7..7985f9d5918cd918e52d84f0f954d04709158c83 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
@@ -111,17 +111,26 @@ public class ConsumerProgressSubCommand implements SubCommand {
                 if (showClientIP) {
                     messageQueueAllocationResult = getMessageQueueAllocationResult(defaultMQAdminExt, consumerGroup);
                 }
-
-                System.out.printf("%-32s  %-32s  %-4s  %-20s  %-20s  %-20s %-20s  %s%n",
-                    "#Topic",
-                    "#Broker Name",
-                    "#QID",
-                    "#Broker Offset",
-                    "#Consumer Offset",
-                    "#Client IP",
-                    "#Diff",
-                    "#LastTime");
-
+                if (showClientIP) {
+                    System.out.printf("%-32s  %-32s  %-4s  %-20s  %-20s  %-20s %-20s  %s%n",
+                            "#Topic",
+                            "#Broker Name",
+                            "#QID",
+                            "#Broker Offset",
+                            "#Consumer Offset",
+                            "#Client IP",
+                            "#Diff",
+                            "#LastTime");
+                } else {
+                    System.out.printf("%-32s  %-32s  %-4s  %-20s  %-20s  %-20s  %s%n",
+                            "#Topic",
+                            "#Broker Name",
+                            "#QID",
+                            "#Broker Offset",
+                            "#Consumer Offset",
+                            "#Diff",
+                            "#LastTime");
+                }
                 long diffTotal = 0L;
                 for (MessageQueue mq : mqList) {
                     OffsetWrapper offsetWrapper = consumeStats.getOffsetTable().get(mq);
@@ -141,17 +150,28 @@ public class ConsumerProgressSubCommand implements SubCommand {
                     if (showClientIP) {
                         clientIP = messageQueueAllocationResult.get(mq);
                     }
-
-                    System.out.printf("%-32s  %-32s  %-4d  %-20d  %-20d  %-20s %-20d  %s%n",
-                        UtilAll.frontStringAtLeast(mq.getTopic(), 32),
-                        UtilAll.frontStringAtLeast(mq.getBrokerName(), 32),
-                        mq.getQueueId(),
-                        offsetWrapper.getBrokerOffset(),
-                        offsetWrapper.getConsumerOffset(),
-                        null != clientIP ? clientIP : "N/A",
-                        diff,
-                        lastTime
-                    );
+                    if (showClientIP) {
+                        System.out.printf("%-32s  %-32s  %-4d  %-20d  %-20d  %-20s %-20d  %s%n",
+                                UtilAll.frontStringAtLeast(mq.getTopic(), 32),
+                                UtilAll.frontStringAtLeast(mq.getBrokerName(), 32),
+                                mq.getQueueId(),
+                                offsetWrapper.getBrokerOffset(),
+                                offsetWrapper.getConsumerOffset(),
+                                null != clientIP ? clientIP : "N/A",
+                                diff,
+                                lastTime
+                        );
+                    } else {
+                        System.out.printf("%-32s  %-32s  %-4d  %-20d  %-20d  %-20d  %s%n",
+                                UtilAll.frontStringAtLeast(mq.getTopic(), 32),
+                                UtilAll.frontStringAtLeast(mq.getBrokerName(), 32),
+                                mq.getQueueId(),
+                                offsetWrapper.getBrokerOffset(),
+                                offsetWrapper.getConsumerOffset(),
+                                diff,
+                                lastTime
+                        );
+                    }
                 }
 
                 System.out.printf("%n");