更新时间:2023-08-16 GMT+08:00

修改Kafka实例Topic

功能介绍

修改Kafka实例Topic

URI

PUT /v2/{project_id}/instances/{instance_id}/topics

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID,获取方式请参见获取项目ID

最小长度:1

最大长度:64

instance_id

String

实例ID。

最小长度:1

最大长度:64

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

topics

Array of topics objects

修改的topic列表。

表3 topics

参数

是否必选

参数类型

描述

id

String

topic名称,不支持修改。

retention_time

Integer

老化时间,单位小时。

sync_replication

Boolean

是否同步复制。

sync_message_flush

Boolean

是否同步落盘。

new_partition_numbers

Integer

分区数。

topic_other_configs

Array of topic_other_configs objects

topic配置

topic_desc

String

topic描述

表4 topic_other_configs

参数

是否必选

参数类型

描述

name

String

配置名称

value

String

配置值

响应参数

请求示例

修改Topic参数,topic-1284340884的老化时间修改为72小时,分区数修改为6,不同步复制,不同步落盘,消息时间类型为LogAppendTime,最大批处理大小10485760。

PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics

{
  "topics" : [ {
    "id" : "test01",
    "retention_time" : 72,
    "sync_replication" : false,
    "sync_message_flush" : false,
    "new_partition_numbers" : 6,
    "topic_other_configs" : [ {
      "name" : "message.timestamp.type",
      "value" : "LogAppendTime"
    }, {
      "name" : "max.message.bytes",
      "value" : 10485760
    } ],
    "topic_desc" : "This is a test topic"
  } ]
}

响应示例

状态码

状态码

描述

204

修改成功。

错误码

请参见错误码