更新时间:2024-04-07 GMT+08:00

(可选)步骤三:创建Topic

Topic,即消息主题。创建Kafka实例成功后,如果没有开启“Kafka自动创建Topic”,需要手动创建Topic,然后才能进行生产消息和消费消息。如果实例开启了“Kafka自动创建Topic”,则该操作为可选,在进行生产时,会自动创建一个Topic,此Topic的默认参数值如下:分区数为3,副本数为3,老化时间为72小时,不开启同步复制和同步落盘。

本文主要介绍在控制台手动创建Topic的操作。

操作步骤

  1. 登录分布式消息服务Kafka控制台,选择Kafka实例所在的区域。
  2. 在“Kafka专享版”页面,单击Kafka实例的名称,进入实例详情页面。
  3. 在“Topic管理”页面,单击“创建Topic”,弹出“创建Topic”对话框。
  4. 填写Topic名称和配置信息,单击“确定”,完成创建Topic。

    表1 Topic参数说明

    参数

    说明

    Topic名称

    设置Topic名称

    创建Topic后不能修改名称。

    分区数

    设置为“3”

    分区数越大消费的并发度越大。

    副本数

    设置为“3”

    Kafka会自动在每个副本上备份数据,当其中一个Broker故障时数据依然是可用的,副本数越大可靠性越高。

    说明:

    实例节点出现故障的情况下,单副本Topic查询消息时可能会报“内部服务错误”,因此不建议使用单副本Topic。

    老化时间(小时)

    设置为“72”

    消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。

    同步复制

    不开启

    同步落盘

    不开启