From 16027bf0c02ff585e683f4261c42874e9b281364 Mon Sep 17 00:00:00 2001 From: SSpirits Date: Wed, 6 Dec 2023 10:17:40 +0800 Subject: [PATCH] feat(cli): add ResetConsumeOffset command Signed-off-by: SSpirits --- cli/src/main/java/com/automq/rocketmq/cli/MQAdmin.java | 4 +++- .../com/automq/rocketmq/cli/consumer/ResetConsumeOffset.java | 2 +- 2 files changed, 4 insertions(+), 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 index 934ac36f2..5fdfd3cce 100644 --- 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 index 0270bebc8..eea8cf585 100644 --- 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 { @CommandLine.Option(names = {"-t", "--topic"}, description = "Topic name", required = true)