feat(cli): add ResetConsumeOffset command (#800)

Signed-off-by: SSpirits <admin@lv5.moe>
AutoMQ · Dec 6, 2023 · 3c47c31 · 3c47c31
1 parent 99c0fb7
commit 3c47c31
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/cli/src/main/java/com/automq/rocketmq/cli/MQAdmin.java b/cli/src/main/java/com/automq/rocketmq/cli/MQAdmin.java
@@ -24,6 +24,7 @@
 import com.automq.rocketmq.cli.consumer.DeleteGroup;
 import com.automq.rocketmq.cli.consumer.DescribeGroup;
 import com.automq.rocketmq.cli.consumer.ListGroup;
+import com.automq.rocketmq.cli.consumer.ResetConsumeOffset;
 import com.automq.rocketmq.cli.consumer.UpdateGroup;
 import com.automq.rocketmq.cli.producer.ProduceMessage;
 import com.automq.rocketmq.cli.stream.DescribeStream;
@@ -54,7 +55,8 @@
         ListGroup.class,
         ProduceMessage.class,
         ConsumeMessage.class,
-        TerminateNode.class
+        TerminateNode.class,
+        ResetConsumeOffset.class
     }
 )
 public class MQAdmin implements Runnable {

diff --git a/cli/src/main/java/com/automq/rocketmq/cli/consumer/ResetConsumeOffset.java b/cli/src/main/java/com/automq/rocketmq/cli/consumer/ResetConsumeOffset.java
@@ -37,7 +37,7 @@
 import org.apache.commons.lang3.tuple.Pair;
 import picocli.CommandLine;
 
-@CommandLine.Command(name = "resetConsumeOffset", description = "Reset consume offset", mixinStandardHelpOptions = true, showDefaultValues = true)
+@CommandLine.Command(name = "resetConsumeOffset", mixinStandardHelpOptions = true, showDefaultValues = true)
 public class ResetConsumeOffset implements Callable<Void> {
 
     @CommandLine.Option(names = {"-t", "--topic"}, description = "Topic name", required = true)