更新时间:2025-08-21 GMT+08:00

配置Kafka自动创建Topic

“Kafka自动创建Topic”表示向一个未创建的Topic生产或消费消息时,系统会自动创建此Topic,此Topic的默认参数值如表1所示。

集群实例支持在“实例管理 > 配置参数”中修改“log.retention.hours”(老化时间)、“default.replication.factor”(副本数)或“num.partitions”(分区数)的参数值,单机实例不支持修改配置参数。修改参数值后自动创建的Topic,Topic参数值为修改后的值。

例如:“num.partitions”修改为“5”,自动创建的Topic参数值如表1所示。

表1 Topic参数值

参数名称

单机实例默认值

集群实例默认值

集群实例修改后的值

分区数

1

3

5

副本数

1

3

3

老化时间

72小时

72小时

72小时

同步复制

不开启

不开启

不开启

同步落盘

不开启

不开启

不开启

消息时间戳类型

CreateTime

CreateTime

CreateTime

批处理消息最大值

10485760字节

10485760字节

10485760字节

约束与限制

开启/关闭“Kafka自动创建Topic”可能会导致实例重启,具体以控制台显示为准。

配置Kafka自动创建Topic

  1. 登录Kafka控制台
  2. 在管理控制台左上角单击,选择Kafka实例所在的区域。
  3. 单击Kafka实例名称,进入“概览”页面。
  4. 在“实例信息”区域的“Kafka自动创建Topic”后,单击,弹出“确认”对话框。
  5. 单击“确定”,跳转到“后台任务管理”页面。任务状态为“成功”时,表示开启/关闭Kafka自动创建Topic成功。

相关文档