當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

rockmq运维指令_RocketMQ 运维指令

發布時間：2023/12/4 编程问答 34 豆豆

生活随笔收集整理的這篇文章主要介紹了 rockmq运维指令_RocketMQ 运维指令小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

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

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%)

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

-s

cSize

-l

lStorePath

-z

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

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

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

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

總結

以上是生活随笔為你收集整理的rockmq运维指令_RocketMQ 运维指令的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： jwt的token自动续约_JWT(JS
下一篇： mysql如何查询某条记录在分页的第几页