分布式消息服务Kafka版-（可选）步骤三：创建Topic:方式2：在Kafka客户端上创建

时间：2023-11-01 16:23:06

方式2：在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 
```