Topic 相关
updateTopic
: 创建/更新 Topic 配置deleteTopic
: 删除 TopictopicList
: 查看 Topic 列表信息topicRoute
: 查看 Topic 路由信息topicStatus
: 查看 Topic 消息队列 offsettopicClusterList
: 查看 Topic 所在集群列表updateTopicPerm
: 更新 Topic 读写权限updateOrderConf
: 从 NameServer 上创建、删除、获取特定命名空间的 kv 配置,目前还未启用allocateMQ
: 以平均负载算法计算消费者列表负载消息队列的负载结果statsAll
: 打印 Topic 订阅关系、TPS、积累量、24h 读写总量等信息
集群相关
clusterList
: 查看集群信息,集群、BrokerName、BrokerId、TPS 等信息clusterRT
: 发送消息检测集群各 Broker RT。消息发往 ${BrokerName} Topic。
Broker 相关
updateBrokerConfig
: 更新 Broker 配置文件,会修改 Broker.confbrokerStatus
: 查看 Broker 统计信息、运行状态(你想要的信息几乎都在里面)brokerConsumeStats
: Broker中各个消费者的消费情况,按 Message Queue 维度返回 Consume Offset,Broker Offset,Diff,TImestamp 等信息getBrokerConfig
: 获取 Broker 配置wipeWritePerm
: 从 NameServer 上清除 Broker 写权限cleanExpiredCQ
: 清理 Broker 上过期的 Consume Queue,如果手动减少对列数可能产生过期队列cleanUnusedTopic
: 清理 Broker 上不使用的 Topic,从内存中释放 Topic 的 Consume Queue,如果手动删除 Topic 会产生不使用的 TopicsendMsgStatus
: 向 Broker 发消息,返回发送状态和 RT
消息相关
queryMsgById
: 根据 offsetMsgId 查询 msg,如果使用开源控制台,应使用 offsetMsgId,此命令还有其他参数,具体作用请阅读 QueryMsgByIdSubCommandqueryMsgByKey
: 根据消息 Key 查询消息queryMsgByOffset
: 根据 Offset 查询消息queryMsgByUniqueKey
: 根据 msgId 查询,msgId 不同于 offsetMsgId,区别详见常见运维问题。-g,-d 配合使用,查到消息后尝试让特定的消费者消费消息并返回消费结果checkMsgSendRT
: 检测向 topic 发消息的 RT,功能类似 clusterRTsendMessage
: 发送一条消息,可以根据配置发往特定 Message Queue,或普通发送。consumeMessage
: 消费消息。可以根据 offset、开始 & 结束时间戳、消息队列消费消息,配置不同执行不同消费逻辑,详见ConsumeMessageCommand。printMsg
: 从 Broker 消费消息并打印,可选时间段printMsgByQueue
: 类似 printMsg,但指定 Message QueueresetOffsetByTime
: 按时间戳重置 offset,Broker 和 consumer 都会重置
消费者、消费组相关
consumerProgress
: 查看订阅组消费状态,可以查看具体的 client IP 的消息积累量consumerStatus
: 查看消费者状态,包括同一个分组中是否都是相同的订阅,分析 Process Queue 是否堆积,返回消费者 jstack结果,内容较多,使用者参见 ConsumerStatusSubCommandupdateSubGroup
: 更新或创建订阅关系deleteSubGroup
: 从 Broker 删除订阅关系cloneGroupOffset
: 在目标群组中使用源群组的 offset
连接相关
consumerConnection
: 查询 Consumer 的网络连接producerConnection
: 查询 Producer 的网络连接
NameServer 相关
updateKvConfig
: 更新 NameServer 的 kv 配置,目前还未使用deleteKvConfig
: 删除 NameServer 的 kv 配置getNamesrvConfig
: 获取 NameServer 配置updateNamesrvConfig
: 修改 NameServer 配置
其他
startMonitoring
: 开启监控进程,监控消息误删、重试队列消息数等