操作场景
在使用 CKafka 进行消息收发前,您需要在已创建好的 CKafka 实例中创建 Topic 资源。生产者需要将消息发送至指定 Topic,消费者通过订阅 Topic 获取消息进行消费。本文介绍在 CKafka 控制台中创建 Topic 的操作步骤。
前提条件
操作步骤
1. 登录 CKafka 控制台 。
2. 在左侧导航栏选择实例列表,找到提前创建好的实例,单击实例的“ID”,进入实例详情页。
3. 在实例详情页选择页面顶部的 Topic 管理页签,单击新建。
4. 在编辑 Topic 窗口中,选择分区数和副本数等信息。
参数 | 说明 |
名称 | Topic 名称,输入后无法更改,名称只能包含字母、数字、下划线、“-”和“.”,不支持以“双下划线”开头。 |
分区数 | 一个 Topic 可以包含一个或者多个 partition,CKafka 以 partition 作为分配单位。部署架构默认至少3节点,分区数起步建议为3,数据分布更均衡。此处可保持默认值。 |
副本数 | Partition 的副本个数,用于保障 Partition 的高可用。为保障数据可靠性,默认开启2副本,此处可保持默认值。 |
标签 | 标签用于从不同维度对资源分类管理。此处可留空。 |
retention.ms | Topic 维度的消息保留时间,范围1分钟到90天。此处可保持默认值。 |
高级配置 | Topic 的高级参数配置。此处可跳过。 |
5. 单击提交完成 Topic 创建。