调用 CreateTopic 接口创建 Topic。
请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。
在RocketMQ 实例中,Topic 是消息发送与接收的基本单元,消息队列 RocketMQ版通过 Topic 对各类消息进行分类管理。消息的生产者将消息发送到 RocketMQ Topic 中,而消息的消费者则通过订阅该 RocketMQ Topic 来消费消息。
说明
每个实例的 Topic 数量配额与实例规格有关,例如各个规格实例可创建的 Topic 数量请参考产品规格。
参数 | 参数类型 | 是否必选 | 示例值 | 说明 |
---|---|---|---|---|
InstanceId | String | 是 | rocketmq-cnai1f0c29ca****x | 实例 ID。 |
TopicName | String | 是 | my_topic | Topic 的名称。
说明
|
QueueNumber | Integer | 是 | 12 | 当前 Topic 的队列数量。
|
MessageType | Integer | 是 | 0 | 消息类型。取值说明如下:
说明
|
Description | String | 否 | 描述信息 | Topic 的描述信息,长度为 0~128 个字符。 |
AccessPolicies | Array of AccessPolicyObject | 否 | / | 每个 RocketMQ 密钥对于当前 Topic 的权限,支持批量设置权限。若未设置,每个密钥对于当前 Topic 维持密钥的默认权限。详细信息请参考AccessPolicyObject。 |
无
POST /?Action=CreateTopic&Version=2023-01-01 HTTP/1.1 Content-Type: application/json Host: rocketmq.volcengineapi.com X-Date: 20210328T100802Z Authorization: HMAC-SHA256 Credential=AK********/20210328/cn-shanghai/rocketmq/request, SignedHeaders=x-date, Signature=******** { "InstanceId": "rocketmq-cnai1f0c29ca****", "TopicName": "rocketmq123", "QueueNumber": 10, "MessageType": 0, "Description": "test", "AccessPolicies": [ { "AccessKey":"2QdEgrGc97AL1p38Fq13****", "Authority": "ALL" } ] }
{ "ResponseMetadata": { "RequestId": "2023022719194098F0DF73611FD95FA1A2", "Action": "CreateTopic", "Version": "2023-01-01", "Service": "RocketMQ", "Region": "cn-shanghai" }, "Result": null }