分布式消息服务KAFKA版-Kafka实例创建Topic:请求消息

时间:2024-01-24 16:40:34

请求消息

请求参数

参数说明见表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
}
support.huaweicloud.com/api-kafka/kafka-api-180614001.html