分布式消息服务-RocketMQ

创建topic

2024-07-02 09:05:30

接口介绍

创建主题。

接口约束

无。

URl

POST https://[endpoint]/v2/topic/create

请求参数

请求参数

是否必填

位置

参数类型

说明

prodInstId

body

String

实例ID

brokerNameList

body

List<String>

需要创建topic的Broker名字列表

allowdConsumerGroups

body

List<String>


topicName

body

String

topic名字

writeQueueNums

body

int

topic的属性,可写queue数量,默认是16

readQueueNums

body

int

topic的属性,可读queue数量,默认是16

perm

body

int

权限:2可写,4可读,6可读写。

默认可读写

order

body

String

是否有序topic,true:有序;false:无序,默认是false

remark

body

String

主题备注信息

响应参数

响应参数

参数类型

描述

statusCode

String

接口系统层面状态码。成功:800,失败:900

message

String

描述状态

returnObj

String

返回对象。此参数所包含的参数请见“响应示例"里面的注释

 

请求示例

POST https://[endpoint]/v2/topic/create

{

    "prodInstId":"mq_test",

    "brokerNameList":[

        "mq_test_broker_1"

    ],

    "writeQueueNums":4,

    "readQueueNums":4,

    "order":"false",

    "perm":6,

    "allowdConsumerGroups":[

 

    ],

    "topicName":"test1"

}

响应成功示例

{

    "returnObj":{

 

    },

    "message":"success",

    "statusCode":800

}

响应失败示例

{

    "returnObj": {},

    "message": "...",

    "statusCode": "900"

}


.9o_5BmBFm5_