RocketMQ mqadmin 常用管理命令

命令"/>

RocketMQ mqadmin 常用管理命令

.html

系列

• RocketMQ mqadmin 常用管理命令
• RocketMQ mqadmin 交互流程

开篇

• 这个系列的主要目的是介绍mqadmin管理工具，在这个系列当中会介绍mqadmin的常用管理命令 和 mqadmin的命令执行流程。

• 这篇文章主要介绍mqadmin的常用管理命令，包括如何查看所有命令以及针对指定命令查看帮助手册等。

常用命令

The most commonly used mqadmin commands are:updateTopic          Update or create topicdeleteTopic          Delete topic from broker and NameServer.updateSubGroup       Update or create subscription groupdeleteSubGroup       Delete subscription group from broker.updateBrokerConfig   Update broker`s configupdateTopicPerm      Update topic permtopicRoute           Examine topic route infotopicStatus          Examine topic Status infotopicClusterList     get cluster info for topicbrokerStatus         Fetch broker runtime status dataqueryMsgById         Query Message by IdqueryMsgByKey        Query Message by KeyqueryMsgByUniqueKey  Query Message by Unique keyqueryMsgByOffset     Query Message by offsetprintMsg             Print Message DetailprintMsgByQueue      Print Message DetailsendMsgStatus        send msg to broker.brokerConsumeStats   Fetch broker consume stats dataproducerConnection   Query producer`s socket connection and client versionconsumerConnection   Query consumer`s socket connection, client version and subscriptionconsumerProgress     Query consumers`s progress, speedconsumerStatus       Query consumer`s internal data structurecloneGroupOffset     clone offset from other group.clusterList          List all of clusterstopicList            Fetch all topic list from name serverupdateKvConfig       Create or update KV config.deleteKvConfig       Delete KV config.wipeWritePerm        Wipe write perm of broker in all name serverresetOffsetByTime    Reset consumer offset by timestamp(without client restart).updateOrderConf      Create or update or delete order confcleanExpiredCQ       Clean expired ConsumeQueue on broker.cleanUnusedTopic     Clean unused topic on broker.startMonitoring      Start MonitoringstatsAll             Topic and Consumer tps statsallocateMQ           Allocate MQcheckMsgSendRT       check message send response timeclusterRT            List All clusters Message Send RTgetNamesrvConfig     Get configs of name server.updateNamesrvConfig  Update configs of name server.getBrokerConfig      Get broker config by cluster or special broker!queryCq              Query cq command.sendMessage          Send a messageconsumeMessage       Consume messageupdateAclConfig      Update acl config yaml file in brokerdeleteAccessConfig   Delete Acl Config Account in brokerclusterAclConfigVersion List all of acl config version information in clusterupdateGlobalWhiteAddr Update global white address for acl Config File in brokergetAccessConfigSubCommand List all of acl config information in clusterSee 'mqadmin help <command>' for more information on a specific command.

查看指定命令

mqadmin updateTopicPerm --helpusage: mqadmin updateTopicPerm [-b <arg>] [-c <arg>] [-h] [-n <arg>] -p <arg> -t <arg>-b,--brokerAddr <arg>    create topic to which broker-c,--clusterName <arg>   create topic to which cluster-h,--help                Print help-n,--namesrvAddr <arg>   Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876-p,--perm <arg>          set topic's permission(2|4|6), intro[2:W; 4:R; 6:RW]-t,--topic <arg>         topic name

mqadmin updateTopic --helpusage: mqadmin updateTopic -b <arg> | -c <arg>  [-h] [-n <arg>] [-o <arg>] [-p <arg>] [-r <arg>] [-s <arg>] -t<arg> [-u <arg>] [-w <arg>]-b,--brokerAddr <arg>       create topic to which broker-c,--clusterName <arg>      create topic to which cluster-h,--help                   Print help-n,--namesrvAddr <arg>      Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876-o,--order <arg>            set topic's order(true|false)-p,--perm <arg>             set topic's permission(2|4|6), intro[2:W 4:R; 6:RW]-r,--readQueueNums <arg>    set read queue nums-s,--hasUnitSub <arg>       has unit sub (true|false)-t,--topic <arg>            topic name-u,--unit <arg>             is unit topic (true|false)-w,--writeQueueNums <arg>   set write queue nums

mqadmin consumerProgress --helpusage: mqadmin consumerProgress [-g <arg>] [-h] [-n <arg>] [-s <arg>]-g,--groupName <arg>      consumer group name-h,--help                 Print help-n,--namesrvAddr <arg>    Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876-s,--showClientIP <arg>   Show Client IP per Queue

执行指定命令

mqadmin topicStatus -n localhost:9876 -t TBW102#Broker Name                      #QID  #Min Offset           #Max Offset             #Last Updated
broker-a                          0     0                     0                       
broker-a                          1     0                     0                       
broker-a                          2     0                     0                       
broker-a                          3     0                     0                       
broker-a                          4     0                     0                       
broker-a                          5     0                     0                       
broker-a                          6     0                     0                       
broker-a                          7     0                     0