修改Kafka实例Topic
功能介绍
修改Kafka实例Topic
URI
PUT /v2/{project_id}/instances/{instance_id}/topics
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
project_id |
是 |
String |
项目ID,获取方式请参见获取项目ID。 |
|
instance_id |
是 |
String |
实例ID。 |
请求参数
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
topics |
否 |
Array of topics objects |
修改的Topic列表。 |
|
参数 |
是否必选 |
参数类型 |
描述 |
|---|---|---|---|
|
id |
是 |
String |
Topic名称,不支持修改。 |
|
retention_time |
否 |
Integer |
老化时间,单位小时。 |
|
sync_replication |
否 |
Boolean |
是否同步复制。 |
|
sync_message_flush |
否 |
Boolean |
是否同步落盘。 |
|
new_partition_numbers |
否 |
Integer |
分区数。 |
|
new_partition_brokers |
否 |
Array of integers |
增加分区时指定broker列表 |
|
topic_other_configs |
否 |
Array of topic_other_configs objects |
Topic配置 |
|
topic_desc |
否 |
String |
Topic描述 |
响应参数
状态码:204
修改成功。
无
请求示例
修改Topic参数,topic-1284340884的老化时间修改为72小时,分区数修改为6,新增分区分布在broker-1和broker-2上,不同步复制,不同步落盘,消息时间类型为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,
"new_partition_brokers" : [ 1, 2 ],
"topic_other_configs" : [ {
"name" : "message.timestamp.type",
"value" : "LogAppendTime"
}, {
"name" : "max.message.bytes",
"value" : 10485760
} ],
"topic_desc" : "This is a test topic"
} ]
}
响应示例
无
状态码
|
状态码 |
描述 |
|---|---|
|
204 |
修改成功。 |
错误码
请参见错误码。