更新时间:2024-04-07 GMT+08:00
(可选)步骤三:创建Topic
Topic,即消息主题。创建Kafka实例成功后,如果没有开启“Kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。如果实例开启了“Kafka自动创建Topic”,则该操作为可选,在进行生产时,会自动创建一个Topic,此Topic的默认参数值如下:分区数为3,副本数为3,老化时间为72小时,不开启同步复制和同步落盘。
本文主要介绍在控制台手动创建Topic的操作。
操作步骤
- 登录分布式消息服务Kafka控制台,选择Kafka实例所在的区域。
- 在“Kafka专享版”页面,单击Kafka实例的名称,进入实例详情页面。
- 在“Topic管理”页面,单击“创建Topic”,弹出“创建Topic”对话框。
- 填写Topic名称和配置信息,单击“确定”,完成创建Topic。
表1 Topic参数说明 参数
说明
Topic名称
设置Topic名称
创建Topic后不能修改名称。
分区数
设置为“3”
分区数越大消费的并发度越大。
副本数
设置为“3”
Kafka会自动在每个副本上备份数据,当其中一个Broker故障时数据依然是可用的,副本数越大可靠性越高。
说明:实例节点出现故障的情况下,单副本Topic查询消息时可能会报“内部服务错误”,因此不建议使用单副本Topic。
老化时间(小时)
设置为“72”
消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。
同步复制
不开启
同步落盘
不开启
后续步骤
父主题: 快速入门