com.alibaba.rocketmq.tools.command.offset
类 ResetOffsetByTimeOldCommand

java.lang.Object
  com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeOldCommand

所有已实现的接口：

SubCommand

public class ResetOffsetByTimeOldCommand
extends Object
implements SubCommand

根据时间来设置消费进度，设置之前要关闭这个订阅组的所有consumer，设置完再启动，方可生效。

构造方法摘要

ResetOffsetByTimeOldCommand()

方法摘要

org.apache.commons.cli.Options	buildCommandlineOptions(org.apache.commons.cli.Options options)
String	commandDesc()
String	commandName()
void	execute(org.apache.commons.cli.CommandLine commandLine, org.apache.commons.cli.Options options, RPCHook rpcHook)
static void	resetOffset(DefaultMQAdminExt defaultMQAdminExt, String consumerGroup, String topic, long timestamp, boolean force, String timeStampStr)

从类 java.lang.Object 继承的方法

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造方法详细信息

ResetOffsetByTimeOldCommand

public ResetOffsetByTimeOldCommand()

方法详细信息

commandName

public String commandName()

指定者：

接口 SubCommand 中的 commandName

commandDesc

public String commandDesc()

指定者：

接口 SubCommand 中的 commandDesc

buildCommandlineOptions

public org.apache.commons.cli.Options buildCommandlineOptions(org.apache.commons.cli.Options options)

指定者：

接口 SubCommand 中的 buildCommandlineOptions

resetOffset

public static void resetOffset(DefaultMQAdminExt defaultMQAdminExt,
                               String consumerGroup,
                               String topic,
                               long timestamp,
                               boolean force,
                               String timeStampStr)
                        throws RemotingException,
                               MQBrokerException,
                               InterruptedException,
                               MQClientException

抛出：

RemotingException

MQBrokerException

InterruptedException

MQClientException

execute

public void execute(org.apache.commons.cli.CommandLine commandLine,
                    org.apache.commons.cli.Options options,
                    RPCHook rpcHook)

指定者：

接口 SubCommand 中的 execute