RocketMQ 提供一个命令行接口管理工具,查询、管理和诊断各种问题。
管理工具是非常友好的。
切换路径到${PACKAGE}/bin,输入命令 bash mqadmin。
命令 | 描述 |
---|---|
updateTopic | 更新或创建主题 |
deleteTopic | 从broker和NameServer删除主题 |
updateSubGroup | 更新或创建订阅组 |
deleteSubGroup | 从broker删除订阅组 |
updateBrokerConfig | 更新broker的配置 |
updateTopicPerm | 更新主题权限 |
topicRoute | 检查主题路由信息 |
topicStatus | 检查主题状态信息 |
topicClusterList | 获取主题集群信息 |
brokerStatus | broker运行状态数据 |
queryMsgById | 通过id查询消息 |
queryMsgByKey | 通过key查询消息 |
queryMsgByUniqueKey | 通过唯一key查询消息 |
queryMsgByOffset | 通过偏移量查询消息 |
printMsg | 打印消息详情 |
sendMsgStatus | 发送消息到broker的状态 |
brokerConsumeStats | 获取broker消息数据状态 |
producerConnection | 查询生产者的socket连接,客户端版本 |
consumerConnection | 查询消费者的socket连接,客户端版本和订阅 |
consumerProgress | 查询消费者的进度,速度 |
consumerStatus | 查询消费者的内部数据结构 |
cloneGroupOffset | 从其他组克隆偏移量 |
clusterList | 集群列表 |
topicList | 从name server获取主题列表 |
updateKvConfig | 创建或更新KV配置 |
deleteKvConfig | 删除KV 配置. |
wipeWritePerm | 擦除所有name server中的broker写权限 |
resetOffsetByTime | 通过(无客户端重启)重置消费者偏移量 |
updateOrderConf | 创建或更新或删除顺序配置 |
cleanExpiredCQ | 清理broker上过期的消费队列 |
cleanUnusedTopic | 清理broker上未被使用的主题 |
startMonitoring | 启动监控 |
statsAll | 主题和消费者tps 状态 |
syncDocs | 同步文档 |
allocateMQ | 分配MQ |
checkMsgSendRT | 检查消息的发送响应时间 |
clusterRT | 集群内所有消息的发送响应时间列表 |
帮助文本列出可能的选项和每个选项的解释。
usage: mqadmin clusterList [-h] [-i <arg>] [-m] [-n <arg>]
-h,--help Print help
-i,--interval <arg> specify intervals numbers, it is in seconds
-m,--moreStats Print more stats
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876