更新时间:2024-05-29 GMT+08:00

配置Kafka自动创建Topic

“Kafka自动创建Topic”表示在生产或消费一个未创建的Topic时,会自动创建此Topic,此Topic的默认参数值如下:

  • 分区数为3。
  • 副本数为3。
  • 老化时间为72小时。
  • 不开启同步复制和同步落盘。
  • 消息时间戳类型为CreateTime。
  • 批处理消息最大值为10485760字节。

如果在“配置参数”中修改“log.retention.hours”、“default.replication.factor”或“num.partitions”的参数值,此后自动创建的Topic参数值为修改后的参数值。

例如:“num.partitions”修改为“5”,自动创建的Topic参数值如下:

  • 分区数为5。
  • 副本数为3。
  • 老化时间为72小时。
  • 不开启同步复制和同步落盘。
  • 消息时间戳类型为CreateTime。
  • 批处理消息最大值为10485760字节。

配置Kafka自动创建Topic

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择Kafka实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 Kafka”,进入分布式消息服务Kafka专享版页面。
  4. 单击Kafka实例名称,进入“基本信息”页面。
  5. 在“实例信息”区域的“Kafka自动创建Topic”后,单击,弹出“确认”对话框。

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

  6. 单击“确认”,完成“Kafka自动创建Topic”的开启/关闭。

    您可以在“后台任务管理”页面,查看开启/关闭任务的执行状态。