更新时间:2024-10-10 GMT+08:00
配置Kafka自动创建Topic
“Kafka自动创建Topic”表示向一个未创建的Topic生产或消费消息时,系统会自动创建此Topic,此Topic的默认参数值如表1所示。
如果在“配置参数”中修改“log.retention.hours”(老化时间)、“default.replication.factor”(副本数)或“num.partitions”(分区数)的参数值,此后自动创建的Topic参数值为修改后的参数值。例如:“num.partitions”修改为“5”,自动创建的Topic参数值如表1所示。
参数名称 |
默认参数值 |
修改后的参数值 |
---|---|---|
分区数 |
3 |
5 |
副本数 |
3 |
3 |
老化时间 |
72小时 |
72小时 |
同步复制 |
不开启 |
不开启 |
同步落盘 |
不开启 |
不开启 |
消息时间戳类型 |
CreateTime |
CreateTime |
批处理消息最大值 |
10485760字节 |
10485760字节 |
配置Kafka自动创建Topic
- 登录管理控制台。
- 在管理控制台左上角单击,选择区域。
请选择Kafka实例所在的区域。
- 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。
- 单击Kafka实例名称,进入“基本信息”页面。
- 在“实例信息”区域的“Kafka自动创建Topic”后,单击或,弹出“确认”对话框。
开启/关闭“Kafka自动创建Topic”可能会导致实例重启,具体以控制台显示为准。
- 单击“确认”,完成“Kafka自动创建Topic”的开启/关闭。
您可以在“后台任务管理”页面,查看开启/关闭任务的执行状态。
父主题: Topic管理