最近更新时间:2024.04.01 17:20:47
首次发布时间:2023.03.30 19:59:25
调用 CreateTopic 接口创建 Kafka Topic。
此接口用于在指定实例下创建一个 Kafka 的 Topic,用户可使用该 Topic 发布和订阅消息。
说明
实例更配过程中,禁止通过任何方式创建 Topic。创建 Topic 之前,请确认实例状态为运行中(Running)。
参数 | 参数类型 | 是否必选 | 示例值 | 说明 |
---|---|---|---|---|
InstanceId | String | 是 | kafka-cnngbnntswg1****x | 实例 ID。 |
TopicName | String | 是 | my_topic | 待创建的 Topic 名称。应符合以下要求:
|
PartitionNumber | Integer | 是 | 12 | Topic 分区数。取值范围为 1~300,如果实例中已创建了其他 Topic,则所有 Topic 的分区数之和不超过该实例的分区数上限。 |
AllAuthority | Boolean | 否 | true | 待创建的 Topic 默认是否对所有用户都开启读写权限。
|
AccessPolicies | Array of AccessPolicyObject | 否 | / | 自定义权限配置,即为某些用户设置对于此 Topic 的自定义权限。仅在 AllAuthority 为 false 时设置。详细信息请参考数据结构中的AccessPolicyObject 部分。 |
Description | String | 否 | 描述信息 | Topic 的描述信息。长度不超过 128 个字符。 |
ReplicaNumber | Integer | 否 | 2 | Topic 副本个数。可设置为 1、2 或 3,默认值为 3。 |
Parameters | String | 否 | {"MessageMaxByte":"11"} | Topic 级别的参数配置。 |
Tags | Array of TagObject | 否 | [{"Key":"keyA","Value":"valueA"}] | 云资源标签。可以将 Topic 通过标签进行归类,便于 Topic 的识别和管理。 |
CleanupPolicy | Array of String | 否 | ["delete"] | Topic 的消息清理策略,支持以下三种取值方式:
注意 如果消息没有 Key,请谨慎启用 COMPACT 消息清理策略。在没有消息 Key 的情况下启用 COMPACT 策略,将会把旧消息都清除掉。 |
Parameters 参数说明
参数 | 参数类型 | 是否必选 | 示例值 | 说明 |
---|---|---|---|---|
MinInsyncReplicaNumber | String | 否 | 1 | 最小同步副本个数。 |
MessageMaxByte | String | 否 | 12 | 最大消息大小。 |
LogRetentionHours | String | 否 | 2160 | 消息保留时长。 |
无
{ "InstanceId": "kafka-cnou8z5z***", "TopicName": "topic-c", "Description": "test", "PartitionNumber": 12, "ReplicaNumber": 3, "AllAuthority": true, "AccessPolicies": [], "Tags": [ { "Key": "usera", "Value": "a" }, { "Key": "userb", "Value": "b" } ], "CleanupPolicy": [ "delete", "compact" ], "Parameters": "{\"MessageMaxByte\":\"10\",\"LogRetentionHours\":\"72\",\"MinInsyncReplicaNumber\":\"2\"}" }
{ "ResponseMetadata": { "RequestId": "20240401143838F51CA32EA4879859FE***", "Action": "CreateTopic", "Version": "2022-05-01", "Service": "kafka", "Region": "cn-guangzhou" }, "Result": null }