1.1.控制台使用

RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理

登录控制台

首先进入RocketMQ 工程，进入/RocketMQ/bin

在该目录下有个mqadmin 脚本

查看帮助

在mqadmin 下可以查看有哪些命令

sh mqadmin

查看具体命令的使用(以具体实现类为准)

sh mqadmin help 命令名称

例如，查看updateTopic 的使用

sh mqadmin help updateTopic

C.详细命令

0.1. help

类路径com.alibaba.rocketmq.tools.command.MQAdminStartup

Option

OptionValue

Detail

-h

help

Print help

e.g. sh mqadmin

e.g. sh mqadmin topicList -h

e.g. sh mqadmin help topicList

0.2. System.setProperty(MixAll.NAMESRV_ADDR_PROPERTY, namesrvAddr);

类路径com.alibaba.rocketmq.tools.command.MQAdminStartup

Option

OptionValue

Detail

-n

namesrvAddr

Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876

备注：-n 指定多个地址时需要用双引号，如 -n “10.128.2.22:9876;172.16.50.238:9876”

原因：linux系统下分号连接两个命令，如果不使用会导致以下错误

错误：-bash: 172.16.50.238:9876: command not found

1.1. Fetch all topic list from name server

指令 topicList

类路径 com.alibaba.rocketmq.tools.command.topic.TopicListSubCommand

Option

OptionValue

Detail

-c

clusterModel

clusterModel

e.g. sh mqadmin topicList -c -n 172.16.50.238:9876

执行结果:

#Cluster Name         #Topic                                            #Consumer Group

DefaultCluster        MMSI_TOPIC                                        MMSI_LOGONCONSUMER_GROUP

DefaultCluster        BenchmarkTest

DefaultCluster        OFFSET_MOVED_EVENT                                __MONITOR_CONSUMER

DefaultCluster        TopicTest

DefaultCluster        broker-a

DefaultCluster        TBW102

DefaultCluster        SELF_TEST_TOPIC

DefaultCluster        DefaultCluster

1.2. Update or create topic

指令 updateTopic

类路径 com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand

Option

OptionValue

Detail

-b

brokerAddr

create subscription group to which broker

-c

clusterName

create subscription group to which cluster

-t

topic

topic name

-r

readQueueNums

set read queue nums

-w

writeQueueNums

set write queue nums

-p

perm

set topic's permission(2|4|6), intro[2:R; 4:W; 6:RW]

-o

order

set topic's order(true|false

-u

unit

is unit topic (true|false

-s

hasUnitSub

has unit sub (true|false

e.g. sh mqadmin updateTopic -b 172.16.50.238:10911 -t test

运行结果：

create topic to 172.16.50.238:10911 success.

TopicConfig [topicName=test, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

查询brokerAddr 见指令 clusterList

查询 topic 见指令 topicList

-b -c 二选一，见具体类文件。

1.3. Delete topic from broker and NameServer.

指令 deleteTopic

类路径 com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand

Option

OptionValue

Detail

-t

topic

topic name

-c

clusterName

delete topic from which cluster

查询clusterName 见指令 clusterList

查询 topic 见指令 topicList

e.g. sh mqadmin deleteTopic -t test -c DefaultCluster -n 172.16.50.238:9876

执行结果：

delete topic [test] from cluster [DefaultCluster] success.

delete topic [test] from NameServer success.

1.4. Examine topic route info

指令 topicRoute

类路径 com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand

Option

OptionValue

Detail

-t

topic

topic name

e.g. sh mqadmin topicRoute -t TopicTest -n 172.16.50.238:9876

执行结果：

{

"brokerDatas":[

{

"brokerAddrs":{0:"172.16.50.238:10911"

},

"brokerName":"broker-a"

}

],

"filterServerTable":{},

"queueDatas":[

{

"brokerName":"broker-a",

"perm":6,

"readQueueNums":4,

"topicSynFlag":0,

"writeQueueNums":4

}

]

}

1.5. Examine topic Status info

指令 topicStatus

类路径com.alibaba.rocketmq.tools.command.topic.TopicStatusSubCommand

Option

OptionValue

Detail

-t

topic

topic name

e.g. sh mqadmin topicStatus -t TopicTest -n 172.16.50.238:9876

#Broker Name                     #QID  #Min Offset            #Max Offset               #Last Updated

broker-a                          0     0                     3275                    2015-05-06 13:06:56,990

broker-a                          1     0                     3270                    2015-05-06 13:00:01,439

broker-a                          2     0                     3270                    2015-05-06 13:00:01,469

broker-a                          3     0                     3270                    2015-05-06 13:00:01,499

1.6. Create or update or delete order conf

指令 updateOrderConf

类路径com.alibaba.rocketmq.tools.command.topic.UpdateOrderConfCommand

Option

OptionValue

Detail

-t

topic

topic name

-v

orderConf

set order conf [eg. brokerName1:num;brokerName2:num]

-m

method

option type [eg. put|get|delete

e.g. sh mqadmin updateOrderConf -t TopicTest -m delete -n 172.16.50.238:9876

2.1. Update or create subscription group

指令 updateSubGroup

类路径 com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand

Option

OptionValue

Detail

-b

brokerAddr

create subscription group to which broker

-c

clusterName

create subscription group to which cluster

-g

groupName

consumer group name

-s

consumeEnable

consume enable

-m

consumeFromMinEnable

from min offset

-d

consumeBroadcastEnable

broadcast

-q

retryQueueNums

retry queue nums

-r

retryMaxTimes

retry max times

-i

brokerId

consumer from which broker id

-w

whichBrokerWhenConsumeSlowly

which broker id when consume slowly

2.2. Delete subscription group from broker.

指令 deleteSubGroup

类路径 com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand

Option

OptionValue

Detail

-b

brokerAddr

delete subscription group from which broker

-c

clusterName

delete subscription group from which cluster

-g

groupName

subscription group name

2.3. Query consumers's progress, speed

指令 consumerProgress

类路径com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

Option

OptionValue

Detail

-g

groupName

consumer group name

e.g. sh mqadmin consumerProgress -g MMSI_LOGONCONSUMER_GROUP -n 172.16.50.238:9876

执行结果:

#Topic                            #Broker Name                      #QID  #Broker Offset        #Consumer Offset      #Diff

MMSI_TOPIC                        broker-a                          0     12                    12                    0

MMSI_TOPIC                        broker-a                          1     4                     4                     0

MMSI_TOPIC                        broker-a                          2     3                     3                     0

MMSI_TOPIC                        broker-a                          3     3                     3                     0

Consume TPS: 0

Diff Total: 0

2.4. Query consumer's internal data structure

指令 consumerStatus

类路径com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

Option

OptionValue

Detail

-g

groupName

consumer group name

e.g. sh mqadmin consumerStatus -g MMSI_LOGONCONSUMER_GROUP -n 172.16.50.238:9876

执行结果：

001  10.128.2.17@MMSI_C1_1430928642588        V3_2_4_SNAPSHOT      1430984926124/10.128.2.17@MMSI_C1_1430928642588

002  10.128.2.17@MMSI_C2_1430928728896        V3_2_4_SNAPSHOT      1430984926124/10.128.2.17@MMSI_C2_1430928728896

2.5. Start Monitoring

指令 startMonitoring

类路径com.alibaba.rocketmq.tools.command.consumer.StartMonitoringSubCommand

Option

OptionValue

Detail

3.1. Update broker's config

指令 updateBrokerConfig

类路径com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

Option

OptionValue

Detail

-b

brokerAddr

update which broker

-c

clusterName

update which cluster

-k

key

config key

-v

value

config value

3.2. Fetch broker runtime status data

指令 brokerStatus

类路径com.alibaba.rocketmq.tools.command.broker.BrokerStatusSubCommand

Option

OptionValue

Detail

-b

brokerAddr

Broker address

e.g. sh mqadmin brokerStatus -b 172.16.50.238:10911

执行结果：

bootTimestamp                   : 1430977761125

brokerVersion                   : 74

brokerVersionDesc               : V3_2_4_SNAPSHOT

commitLogDiskRatio              : 0.057690158621641695

commitLogMaxOffset              : 1828298

commitLogMinOffset              : 0

consumeQueueDiskRatio           : 0.057690158621641695

dispatchMaxBuffer               : 0

getFoundTps                     : 0.0 0.0 0.0

getMessageEntireTimeMax         : 2

getMissTps                      : 1.996007984031936 1.9958751912713726 1.995861912967115

getTotalTps                     : 1.996007984031936 1.9958751912713726 1.995861912967115

getTransferedTps                : 0.0 0.0 0.0

msgGetTotalTodayMorning         : 0

msgGetTotalTodayNow             : 22

msgGetTotalYesterdayMorning     : 0

msgPutTotalTodayMorning         : 0

msgPutTotalTodayNow             : 0

msgPutTotalYesterdayMorning     : 0

putMessageAverageSize           : 0.0

putMessageDistributeTime        :

0(0.0%)

0(0.0%)

0(0.0%)

0(0.0%)

0(0.0%)

0(0.0%)

0(0.0%)

putMessageEntireTimeMax         : 0

putMessageSizeTotal             : 0

putMessageTimesTotal            : 1

putTps                          : 0.0 0.0 0.0

runtime                         : [ 0 days, 2 hours, 3 minutes, 44 seconds ]

sendThreadPoolQueueCapacity     : 100000

sendThreadPoolQueueSize         : 0

3.3. Clean expired ConsumeQueue on broker.

指令 cleanExpiredCQ

类路径com.alibaba.rocketmq.tools.command.broker.CleanExpiredCQSubCommand

Option

OptionValue

Detail

-b

brokerAddr

Broker address

-c

cluster

clustername

4.1. Query Message by Id

指令 queryMsgById

类路径com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand

Option

OptionValue

Detail

-i

msgId

Message Id

-g

consumerGroup

consumer group name

-d

clientId

The consumer's client id

e.g. sh mqadmin queryMsgById -i AC1032EE00002A9F00000000001BE5CA -n 172.16.50.238:9876

执行结果：

Topic:               TopicTest

Tags:                [TagA]

Keys:                [null]

Queue ID:            0

Queue Offset:        3275

CommitLog Offset:    1828298

Reconsume Times:     0

Born Timestamp:      2015-05-07 16:04:45,282

Store Timestamp:     2015-05-07 16:04:29,589

Born Host:           172.16.10.103:64888

Store Host:          172.16.50.238:10911

System Flag:         0

Properties:          {WAIT=true, TAGS=TagA}

Message Body Path:   /tmp/rocketmq/msgbodys/AC1032EE00002A9F00000000001BE5CA

4.2. Query Message by Key

指令 queryMsgByKey

类路径com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand

Option

OptionValue

Option

-t

topic

topic name

-k

msgKey

Message Key

e.g. sh mqadmin queryMsgByKey -t TopicTest -k key1 -n 172.16.50.238:9876

执行结果：

#Message ID                                            #QID                                  #Offset

AC1032EE00002A9F00000000001BE652                      0                                     3276

消息发送部分代码：

// new Message(String topic, String tags, String keys, byte[] body)

Message msg = new Message("TopicTest",

"TagA",

"key1",

("Hello RocketMQ " + i).getBytes()

);

4.3. Query Message by offset

指令 queryMsgByOffset

类路径com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

Option

OptionValue

Detail

-t

topic

topic name

-b

brokerName

Broker Name

-i

queueId

Queue Id

-o

offset

Queue Offset

e.g. sh mqadmin  queryMsgByOffset -t TopicTest -b broker-a -i 0 -o 3275 -n 172.16.50.238:9876

执行结果：

Topic:               TopicTest

Tags:                [TagA]

Keys:                [null]

Queue ID:            0

Queue Offset:        3275

CommitLog Offset:    1828298

Reconsume Times:     0

Born Timestamp:      2015-05-07 16:04:45,282

Store Timestamp:     2015-05-07 16:04:29,589

Born Host:           172.16.10.103:64888

Store Host:          172.16.50.238:10911

System Flag:         0

Properties:          {WAIT=true, TAGS=TagA}

Message Body Path:   /tmp/rocketmq/msgbodys/AC1032EE00002A9F00000000001BE5CA

4.4. Check Message Store

指令 checkMsg

类路径com.alibaba.rocketmq.tools.command.message.CheckMsgSubCommand

Option

OptionValue

Detail

-p

cStorePath

cStorePath

-s

cSize

cSize

-l

lStorePath

lStorePath

-z

lSize

lSize

4.5. Print Message Detail

指令 printMsg

类路径com.alibaba.rocketmq.tools.command.message.PrintMessageSubCommand

Option

OptionValue

Detail

-t

topic

topic name

-c

charsetName

CharsetName(eg: UTF-8、GBK)

-s

subExpression

Subscribe Expression(eg: TagA || TagB)

-b

beginTimestamp

Begin timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]

-e

endTimestamp

End timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]

e.g. sh mqadmin printMsg -t TopicTest -c UTF-8 -s TagA -n 172.16.50.238:9876

执行结果：

MSGID: AC1032EE00002A9F0000000000000198 MessageExt [queueId=3, storeSize=136, queueOffset=0, sysFlag=0, bornTimestamp=1430276116906, bornHost=/172.16.10.103:18048, storeTimestamp=1430276075650, storeHost=/172.16.50.238:10911, msgId=AC1032EE00002A9F0000000000000198, commitLogOffset=408, bodyCRC=1032136437, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=3270, WAIT=true, TAGS=TagA}, body=16]] BODY: Hello RocketMQ 3

MSGID: AC1032EE00002A9F00000000000003B8 MessageExt [queueId=3, storeSize=136, queueOffset=1, sysFlag=0, bornTimestamp=1430276117046, bornHost=/172.16.10.103:18048, storeTimestamp=1430276075794, storeHost=/172.16.50.238:10911, msgId=AC1032EE00002A9F00000000000003B8, commitLogOffset=952, bodyCRC=988340972, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=3270, WAIT=true, TAGS=TagA}, body=16]] BODY: Hello RocketMQ 7

MSGID: AC1032EE00002A9F00000000000005D9 MessageExt [queueId=3, storeSize=137, queueOffset=2, sysFlag=0, bornTimestamp=1430276117187, bornHost=/172.16.10.103:18048, storeTimestamp=1430276075930, storeHost=/172.16.50.238:10911, msgId=AC1032EE00002A9F00000000000005D9, commitLogOffset=1497, bodyCRC=2088767104, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=3270, WAIT=true, TAGS=TagA}, body=17]] BODY: Hello RocketMQ 11

MSGID: AC1032EE00002A9F00000000000007FD MessageExt [queueId=3, storeSize=137, queueOffset=3, sysFlag=0, bornTimestamp=1430276117312, bornHost=/172.16.10.103:18048, storeTimestamp=1430276076058, storeHost=/172.16.50.238:10911, msgId=AC1032EE00002A9F00000000000007FD, commitLogOffset=2045, bodyCRC=2079181465, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=3270, WAIT=true, TAGS=TagA}, body=17]] BODY: Hello RocketMQ 15

省略

5.1. Query producer's socket connection and client version

指令 producerConnection

类路径com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubCommand

Option

OptionValue

Detail

-g

producerGroup

producer group name

-t

topic

topic name

e.g. sh mqadmin producerConnection -t MMSI_TOPIC -g MMSI_LOGONPRODUCER_GROUP -n 10.128.2.22:9876

执行结果：

0001  10.128.2.21@MMSI_P_1430929646654 10.128.2.21:32772      JAVA     V3_2_4_SNAPSHOT

0002  10.128.2.20@MMSI_P_1430929321115 10.128.2.20:46473      JAVA     V3_2_4_SNAPSHOT

0003  10.128.2.21@MMSI_P_1430929575217 10.128.2.21:60998      JAVA     V3_2_4_SNAPSHOT

0004  10.128.2.19@MMSI_P_1430931090492 10.128.2.19:37579      JAVA     V3_2_4_SNAPSHOT

0005  10.128.2.19@MMSI_P_1430930993253 10.128.2.19:37555      JAVA     V3_2_4_SNAPSHOT

0006  10.128.2.18@MMSI_P_1430928908940 10.128.2.18:59844      JAVA     V3_2_4_SNAPSHOT

0007  10.128.2.18@MMSI_P_1430928940356 10.128.2.18:59872      JAVA     V3_2_4_SNAPSHOT

0008  10.128.2.17@MMSI_P_1430928637687 10.128.2.17:52707      JAVA     V3_2_4_SNAPSHOT

0009  10.128.2.20@MMSI_P_1430929358523 10.128.2.20:46690      JAVA     V3_2_4_SNAPSHOT

0010  10.128.2.17@MMSI_P_1430928722339 10.128.2.17:52634      JAVA     V3_2_4_SNAPSHOT

5.2. Query consumer's socket connection, client version and subscription

指令 consumerConnection

类路径com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand

Option

OptionValue

Detail

-g

consumerGroup

consumer group name

e.g. sh mqadmin consumerConnection -g MMSI_LOGONCONSUMER_GROUP -n 10.128.2.22:9876

执行结果：

001  10.128.2.17@MMSI_C2_1430928643191 10.128.2.17:52732      JAVA     V3_2_4_SNAPSHOT

002  10.128.2.21@MMSI_C1_1430929651766 10.128.2.21:32773      JAVA     V3_2_4_SNAPSHOT

003  10.128.2.20@MMSI_C1_1430929363864 10.128.2.20:46711      JAVA     V3_2_4_SNAPSHOT

004  10.128.2.19@MMSI_C1_1430931095730 10.128.2.19:36999      JAVA     V3_2_4_SNAPSHOT

005  10.128.2.18@MMSI_C1_1430928913978 10.128.2.18:59867      JAVA     V3_2_4_SNAPSHOT

006  10.128.2.20@MMSI_C2_1430929327217 10.128.2.20:46535      JAVA     V3_2_4_SNAPSHOT

007  10.128.2.19@MMSI_C1_1430930998362 10.128.2.19:37557      JAVA     V3_2_4_SNAPSHOT

008  10.128.2.21@MMSI_C2_1430929581143 10.128.2.21:61000      JAVA     V3_2_4_SNAPSHOT

009  10.128.2.18@MMSI_C2_1430928914953 10.128.2.18:59899      JAVA     V3_2_4_SNAPSHOT

010  10.128.2.17@MMSI_C1_1430928642588 10.128.2.17:52727      JAVA     V3_2_4_SNAPSHOT

011  10.128.2.17@MMSI_C1_1430928727537 10.128.2.17:52670      JAVA     V3_2_4_SNAPSHOT

012  10.128.2.18@MMSI_C2_1430928946637 10.128.2.18:59939      JAVA     V3_2_4_SNAPSHOT

013  10.128.2.17@MMSI_C2_1430928728896 10.128.2.17:52696      JAVA     V3_2_4_SNAPSHOT

014  10.128.2.21@MMSI_C1_1430929580732 10.128.2.21:60999      JAVA     V3_2_4_SNAPSHOT

015  10.128.2.18@MMSI_C1_1430928945559 10.128.2.18:59905      JAVA     V3_2_4_SNAPSHOT

016  10.128.2.20@MMSI_C1_1430929326429 10.128.2.20:46474      JAVA     V3_2_4_SNAPSHOT

017  10.128.2.19@MMSI_C2_1430930998829 10.128.2.19:37556      JAVA     V3_2_4_SNAPSHOT

018  10.128.2.21@MMSI_C2_1430929652131 10.128.2.21:32774      JAVA     V3_2_4_SNAPSHOT

019  10.128.2.19@MMSI_C2_1430931095854 10.128.2.19:37000      JAVA     V3_2_4_SNAPSHOT

020  10.128.2.20@MMSI_C2_1430929364329 10.128.2.20:46720      JAVA     V3_2_4_SNAPSHOT

Below is subscription:

001  Topic: MMSI_TOPIC                               SubExpression: MMSI_USERLOGON_TAG

002  Topic: %RETRY%MMSI_LOGONCONSUMER_GROUP          SubExpression: *

ConsumeType: CONSUME_PASSIVELY

MessageModel: CLUSTERING

ConsumeFromWhere: CONSUME_FROM_FIRST_OFFSET

6.1. List all of clusters

指令 clusterList

类路径com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand

Option

OptionValue

Detail

-m

moreStats

Print more stats

e.g. sh mqadmin clusterList -m -n 172.16.50.238:9876

执行结果：

#Cluster Name     #Broker Name      #InTotalYest     #OutTotalYest   #InTotalToday   #OutTotalToday

DefaultCluster    broker-a                     0                0             2            9292

7.1. Create or update KV config.

指令 updateKvConfig

类路径com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand

Option

OptionValue

Detail

-s

namespace

set the namespace

-k

key

set the key name

-v

value

set the key value

7.2. Delete KV config.

指令 deleteKvConfig

类路径com.alibaba.rocketmq.tools.command.namesrv.DeleteKvConfigCommand

Option

OptionValue

Detail

-s

namespace

set the namespace

-k

key

set the key name

7.2. Create or update project group by server ip.

指令 updateProjectGroup

类路径 com.alibaba.rocketmq.tools.command.namesrv.UpdateProjectGroupCommand

Option

OptionValue

Detail

-i

ip

set the server ip

-p

project

set the project group

7.3. Delete project group by server ip.

指令 deleteProjectGroup

类路径com.alibaba.rocketmq.tools.command.namesrv.DeleteProjectGroupCommand

Option

OptionValue

Detail

-i

ip

set the server ip

-p

project

set the project group

7.4. Get project group by server ip or project group name.

指令 getProjectGroup

类路径com.alibaba.rocketmq.tools.command.namesrv.GetProjectGroupCommand

Option

OptionValue

Detail

-i

ip

set the server ip

-p

project

set the project group

7.5. Wipe write perm of broker in all name server

指令 wipeWritePerm

类路径com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand

Option

OptionValue

Detail

-b

brokerName

broker name

8.1. Reset consumer offset by timestamp(without client restart).

指令 resetOffsetByTime

类路径com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeCommand

Option

OptionValue

Detail

-g

group

set the consumer group

-t

topic

set the topic

-s

timestamp

set the timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]

-f

force

set the force rollback by timestamp switch[true|false]

8.2. Reset consumer offset by timestamp(execute this command required client restart).

指令 resetOffsetByTime

类路径com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeCommand

Option

OptionValue

Detail

-g

group

set the consumer group

-t

topic

set the topic

-s

timestamp

set the timestamp[currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS]

-f

force

set the force rollback by timestamp switch[true|false]

8.3. get consumer status from client.

指令 getConsumerStatus

类路径 com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand

Option

OptionValue

Detail

-g

group

set the consumer group

-t

topic

set the topic

-i

originClientId

set the consumer clientId

8.4. clone offset from other group.

指令 cloneGroupOffset

类路径 com.alibaba.rocketmq.tools.command.offset.CloneGroupOffsetCommand

Option

OptionValue

Detail

-s

srcGroup

set source consumer group

-d

destGroup

set destination consumer group

-t

topic

set the topic

-o

offline

the group or the topic is offline