-p -h -n 举 例 是 project group名 否 打印帮助 是 nameserve服务地址列表,格式ip:port;ip:port;... 1.2.22. 设置消费进度 l 根据时间来设置消费进度,设置之前要关闭这个订阅组的所有consumer,设置完再启动,方可生效 指resetOffsetByTime 类com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeSubCommand 令 路径 参数 是说明 否必填 -f -s 否 通过时间戳强制回滚(true|false),默认为true 是 时间戳 (currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS) -g -t -h -n 举 是 消费者所属组名 是 topic名称 否 打印帮助 是 nameserve服务地址列表,格式ip:port;ip:port;... 例 1.2.23. 清除特定Broker权限 指wipeWritePerm 类com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand 令 路径 参数 是说明 否必填 -b -h -n 举 例 是 broker地址 否 打印帮助 是 nameserve服务地址列表,格式ip:port;ip:port;... 1.2.24. 获取Consumer消费进度 l 该命令只打印当前与cluster连接的consumer的消费进度 指getConsumerStatus 类com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand 令 路径 参数 是说明 否必填 -g -t -i -h -n 是 消费者所属组名 是 查询主题 否 Consumer客户端ip 否 打印帮助 是 nameserve服务地址列表,格式ip:port;ip:port;... 举查询属于group(消费者组)=simple-consumer-test的消费者在Topic=ZTEExample上的消例 费状态,nameserve地址为10.45.47.168:9876 sh mqadmin getConsumerStatus -n 10.45.47.168:9876 -g simple-consumer-test -t ZTEExample get consumer status from client. group=simple-consumer-test, topic=ZTEExample, originClientId= #clientId #brokerName #queueId #offset 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 4 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 0 2 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 3 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 1 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 5 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 6 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 7 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 2 0 1.3网址
http://blog.csdn.net/zhu_tianwei/article/details/40951301