分布式消息服务KAFKA版-快速连接Kafka并生产消费消息:步骤三:创建Topic

时间:2024-07-03 09:09:48

步骤三:创建Topic

  1. 在“Kafka专享版”页面,单击Kafka实例的名称,进入实例详情页面。
  2. 在左侧导航栏单击“Topic管理”,进入Topic列表页。
  3. 单击“创建Topic”,弹出“创建Topic”对话框。
  4. 填写Topic名称和配置信息,配置详情请参考表6,单击“确定”,完成创建Topic。

    表6 Topic参数说明

    参数

    说明

    Topic名称

    名称支持自定义,但需要符合命名规则:以英文字母、数字、下划线开头,且只能由英文字母、数字、句点、中划线、下划线组成,长度为3~200个字符。

    名称不能为以下内置Topic:

    • _consumer_offsets
    • _transaction_state
    • _trace
    • _connect-status
    • _connect-configs
    • _connect-offsets

    创建Topic后不能修改名称。

    输入“topic-01”。

    分区数

    如果分区数与消费者数一致,分区数越大消费的并发度越大。

    输入“3”。

    副本数

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

    输入“3”。

    老化时间(小时)

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

    输入“72”。

    同步复制

    选择“不开启”,即Leader副本接收到消息并成功写入到本地日志后,就马上向客户端发送写入成功的消息,不需要等待所有Follower副本复制完成。

    同步落盘

    选择“不开启”,即生产的消息存在内存中,不会立即写入磁盘。

    消息时间戳类型

    选择“CreateTime”,即生产者创建消息的时间。

    批处理消息最大值(字节)

    Kafka允许的最大批处理大小,如果在生产客户端配置文件或代码中启用消息压缩,则表示压缩后的最大批处理大小。

    输入“10485760”。

    描述

    不设置。

    图6 创建Topic

support.huaweicloud.com/qs-kafka/kafka-qs-0409001.html