更新时间:2024-01-24 GMT+08:00

Kafka实例创建Topic

当前页面API为历史版本API,未来可能停止维护。请使用Kafka实例创建Topic

功能介绍

该接口用于向Kafka实例创建Topic。

URI

POST /v1.0/{project_id}/instances/{instance_id}/topics

参数说明见表1

表1 参数说明

参数

类型

必选

说明

project_id

String

项目ID。

instance_id

String

实例ID

请求消息

请求参数

参数说明见表2

表2 参数说明

参数

类型

是否必选

说明

id

String

topic名称,长度为4-64,以字母开头且只支持大小写字母、中横线、下划线以及数字。

partition

Integer

topic分区数,设置消费的并发数。

默认值为3,取值范围为1~100。

replication

Integer

副本数,配置数据的可靠性

默认值为3,取值范围为1~3。

sync_replication

Boolean

是否开启同步复制,开启后,客户端生产消息时相应的也要设置acks=-1,否则不生效。

默认关闭。

retention_time

Integer

消息老化时间。默认值为72。

取值范围1~720,单位小时。

sync_message_flush

Boolean

是否使用同步落盘。默认值为false。同步落盘会导致性能降低。

请求示例

POST https://{dms_endpoint}/v1.0/{project_id}/instances/{instance_id}/topics
{
  "id" : "haha", 
  "partition" : 3, 
  "replication" : 3, 
  "sync_replication " : true, 
  "retention_time" : 10, 
  "sync_message_flush" : true
}

响应消息

响应参数

参数说明见表3

表3 参数说明

参数

类型

说明

id

String

topic名称

响应示例

{  
"id": "haha"
}

状态码

操作成功的状态码如表4所示,其他响应见状态码

表4 状态码

状态码

描述

200

创建成功。