文档首页> 分布式消息服务Kafka版> 用户指南 (阿布扎比区域)> 快速入门> （可选）步骤三：创建Topic
更新时间：2023-05-06 GMT+08:00
查看PDF

（可选）步骤三：创建Topic

Topic，即消息主题。创建Kafka实例成功后，如果没有开启“Kafka自动创建Topic”，需要手动创建Topic，然后才能进行生产消息和消费消息。如果实例开启了“Kafka自动创建Topic”，则该操作为可选，在进行生产时，会自动创建一个Topic，此Topic的默认参数值如下：分区数为3，副本数为3，老化时间为72小时，不开启同步复制和同步落盘。

本文主要介绍手动创建Topic的操作，有以下三种方式，您可以根据实际情况选择任意一种方式：

方式1：在控制台创建

  1. 登录分布式消息服务Kafka控制台，选择Kafka实例所在的区域。
  2. 在“Kafka专享版”页面，单击Kafka实例的名称，进入实例详情页面。
  3. 在“Topic管理”页签，单击“创建Topic”，弹出“创建Topic”对话框。
  4. 填写Topic名称和配置信息，单击“确定”，完成创建Topic。

方式2：在Kafka Manager创建

登录Kafka Manager后，在页面顶部选择“Topic > Create”，然后按照界面参数填写即可。

Topic名称开头包含特殊字符，例如下划线“_”、#号“#”时，监控数据无法展示。

方式3：在Kafka客户端上创建

仅在Kafka客户端版本为2.2以上时，支持通过kafka-topics.sh创建Topic，以及管理Topic的各类参数。

Topic名称开头包含特殊字符，例如下划线“_”、#号“#”时，监控数据无法展示。

  • 未开启SASL的Kafka专享版实例，在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令创建Topic。
    ./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num}
  • 已开启SASL的Kafka专享版实例，通过以下步骤创建Topic。
    1. （可选）如果已经设置了SSL证书配置，请跳过此步骤。否则请执行以下操作。

      在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考使用SASL证书连接增加SSL证书配置。

    2. 在“/{命令行工具所在目录}/kafka_{version}/bin/”目录下，通过以下命令创建Topic。
      ./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num} --command-config ./config/ssl-user-config.properties

后续步骤

步骤四：连接实例生产消费消息

父主题： 快速入门