华为云首页用户手册

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

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

时间：2024-12-31 11:41:05

分布式消息服务KAFKA版

步骤三：创建Topic

在“Kafka专享版”页面，单击Kafka实例的名称，进入实例详情页面。
在左侧导航栏单击“Topic管理”，进入Topic列表页。
单击“创建Topic”，弹出“创建Topic”对话框。

填写Topic名称和配置信息，配置详情请参考表7，单击“确定”，完成创建Topic。

表7 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”。
描述	不设置。

图8 创建Topic
点击放大

点击放大

上一篇：分布式消息服务RABBITMQ版-快速连接RabbitMQ并生产消费消息:步骤三：连接实例生产消费消息

下一篇：分布式消息服务RABBITMQ版-如何配置安全组？

新客秒杀 2核2G 3M L实例

68元/年

普惠上云领千元上云礼券

立即前往

企业专享 X实例 4核8G 5M

888元/年

热门域名 1元随心购

1元/年起

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

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题