步骤二:创建主题
更新时间:2024-10-24
概述
本文介绍在已完成消息服务 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 | 控制日志的滚动时间,超过该时间后的旧数据可以进行删除或者压缩。 |
- 点击“确定”按钮完成主题创建。