查询topic列表

服务说明

服务地址 http://{{xconsole_host}}/rocketmqx/topic/list
服务协议 HTTP POST

参数说明

请求参数：

字段 类型 含义
namesrvAddr String rocketmq集群的namesrv

响应参数：

字段 类型 父节点 含义
resultCode String NA 结果编码，TRUE标识成功，FALSE标识失败
resultMsg String NA 提示信息
resultObject Object NA 结果对象
topicList String[] resultObject 主题列表，其中%RETRY%打头的重试主题，%DLQ%为死信队列，RMQ_SYS_TRANS_HALF_TOPIC为半消息队列

样例报文

请求报文：
{"namesrvAddr": "centos2:9876" }

响应报文：
{
“resultCode”: “TRUE”,
“resultMsg”: “操作成功。”,
“resultObject”: {
“topicList”: [
“RMQ_SYS_TRANS_HALF_TOPIC”,
“%RETRY%C_TopicTest”,
“%RETRY%please_rename_unique_group_name_4”,
“BenchmarkTest”,
“OFFSET_MOVED_EVENT”,
“TBW102”,
“SELF_TEST_TOPIC”,
“%DLQ%C_TopicTest”,
“DefaultCluster”,
“DefaultCluster_REPLY_TOPIC”,
“b-centos2”,
“TopicTest”,
“%RETRY%TOOLS_CONSUMER”
]
},
“success”: true
}

topic 消费进度查询

服务说明

服务地址 http://{{xconsole_host}}/rocketmqx/topic/stats/list
服务协议 HTTP POST

参数说明

请求参数：

字段 类型 含义
namesrvAddr String rocketmq集群的namesrv
topics String[] 主题列表

响应参数：

字段 类型 父节点 含义
resultCode String NA 结果编码，TRUE标识成功，FALSE标识失败
resultMsg String NA 提示信息
resultObject Object NA 结果对象
topicStats topicStat[] resultObject key 为 topic名
topicStat Object topicStats 消费信息
group String topicStat 消费组名
count int topicStat
consumeTps int topicStat 消费tps
diffTotal int topicStat 消费延迟

样例报文

请求报文：
{"namesrvAddr": "centos2:9876", "topics": ["TopicTest"]}

响应报文：
{
“resultCode”: “TRUE”,
“resultMsg”: “操作成功。”,
“resultObject”: {
“TopicTest”: [
{
“group”: “C_TopicTest”,
“count”: 0,
“consumeTps”: 0,
“diffTotal”: 0
},
{
“group”: “please_rename_unique_group_name_4”,
“count”: 0,
“consumeTps”: 0,
“diffTotal”: 1558937
}
]
},
“success”: true
}

消息迁移

服务说明

服务地址 http://{{xconsole_host}}/rocketmqx/migrate
服务协议 HTTP POST

参数说明

请求参数：

字段 类型 父节点 含义
namesrvAddr String NA rocketmq集群的源namesrv
targetNamesrvAddr String NA rocketmq集群的目标namesrv
topic String NA 迁移的topic
consumeGroup String NA 源rocketmq的主题对应的消费者分组，如果没有指定，则要求topic只能有一个消费者分组
tags String NA 消息tag，可空
option Object NA 迁移参数，不填则默认为高可靠方式
migrateType String option 迁移类型：
HR — High Reliable（高可靠方式：批量条数1，消息消费确认方式sync，消息发送确认方式sync） HP — High Performance（高性能方式：批量次数32， 消息消费确认方式async， 消息发送确认方式 async）
pullBatchSize int option 批量条数 <= 32
pullThreadSize int option 拉取线程数 默认一个线程，正常情况单线程的处理效率是绝对够的
pullAckOption String option 消息消费确认方式：sync同步，async异步
sendAckOption String option 消息发送确认方式： sync同步，async异步
timeout int option 超时时间 — 迁移消息（无消息） 默认5秒
count int option 超时次数 — 迁移消息（无消息） 默认3次
retry int option 单批次消息异常重试次数— 默认为3次
ackOption String option 迁移确认方式： sync方式，async异步

响应参数：

字段 类型 父节点 含义
resultCode String NA 结果编码，TRUE标识成功，FALSE标识失败
resultMsg String NA 提示信息
resultObject Object NA 结果对象

样例报文

请求报文：
{
“namesrvAddr”: “centos2:9876”,
“targetNamesrvAddr”: “centos3:9876”,
“topic”: “TopicTest”,
“consumeGroup”: “C_TopicTest”,
“tags”: “TagA”,
“option”: {
“pullBatchSize”: 11,
“sendAckOption”: “async”
}
}

响应报文：
{
“resultCode”: “TRUE”,
“resultMsg”: “操作成功。”,
“success”: true
}