步骤二：创建主题
更新时间：2023-06-30
概述
本文介绍在已完成消息服务 for Kafka专享版集群创建后，如何通过管理控制台创建主题。
前提条件
- 已完成百度智能云账号注册
- 步骤一：已创建Kafka集群
具体操作步骤
- 登录百度智能云消息服务 for Kafka专享版控制台。
- 在集群列表中，点击对应的集群名称进入该集群的集群详情页。
- 左侧模块选择栏选择“主题管理”。
- 点击主题列表左上角“创建主题”按钮进入主题创建页。
- 在集群创建页面，配置以下信息：
| 配置项 | 说明 |
|---|---|
| 主题名称 | 主题名称，具体规则如下：大小写字母、数字以及_-特殊字符，长度1-125 |
| 分区数 | 主题对应分区数。 |
| 副本数 | 主题副本数目。 |
| 高级配置 | 点击“添加配置项”可对高级配置项进行配置。当前支持对6项主题高级配置项内容进行变更，若不单独进行配置，则统一取默认值。 |
主题的高级配置项可以参考以下说明进行配置：
| 配置项 | 默认值 | 说明 |
|---|---|---|
| cleanup.policy | delete | Kafka对于旧日志数据的保留策略，可以选择：delete：旧的日志税局会被删除。compact：对旧日志信息进行压缩。 |
| max.message.bytes | 1048588 bytes | Kafka允许单次发送批数据的最大大小。 |
| message.timestamp.type | CreateTime | 消息中的时间戳来源，可以选择：CreateTime：生产者创建消息时的时间戳。LogAppendTime：服务端追加消息时的时间戳。 |
| min.insync.replicas | 1 | 当生产者发送消息时，将acks参数设置为all时，该配置项会确保最少多少个节点成功写入数据，如果成功写入数据的节点数小于该值，生产者则会出现异常。 |
| retention.ms | 172800000 ms | 消息保留时间，超过该时间后消息会过期删除。 |
| segment.ms | 604800000 ms | 控制日志的滚动时间，超过该时间后的旧数据可以进行删除或者压缩。 |
- 点击“确定”按钮完成主题创建