分布式消息服务KAFKA版-创建Kafka Topic:方式3：在Kafka客户端上创建Topic

时间：2024-07-03 09:09:40

分布式消息服务KAFKA版配置Topic

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

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

Topic名称开头包含特殊字符，例如#号“#”时，监控数据无法展示。
已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，无法通过客户端创建Topic。

未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令创建Topic。

./kafka-topics.sh --create --topic ${topic-name} --bootstrap-server ${connection-address} --partitions ${number-of-partitions} --replication-factor ${number-of-replicas}

已开启密文接入的Kafka实例，通过以下步骤创建Topic。
1. （可选）Kafka安全协议为“SASL_PLAINTEXT”还是“SASL_SSL”？
  - SASL_PLAINTEXT：如果已经设置了用户名和密码，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码。
  - SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，参考3增加用户名和密码，以及SSL证书配置。
2. 在Kafka客户端的“/bin”目录下，通过以下命令创建Topic。
```
./kafka-topics.sh --create --topic ${topic-name} --bootstrap-server ${connection-address} --partitions ${number-of-partitions} --replication-factor ${number-of-replicas} --command-config ./config/ssl-user-config.properties 
```