5.7. 创建主题

创建主题

1. 使用 kafka-topics.sh 实用程序创建主题并指定以下内容：

   • 在 --bootstrap-server 选项中 Kafka 代理的主机和端口。
   • 要在 --create 选项中创建的新主题。
   • --topic 选项中的主题名称。
   • --partitions 选项中的分区数量。

   • --replication-factor 选项中的主题复制因素。

     您还可以使用 --config 选项覆盖某些默认主题配置选项。这个选项可以多次用于覆盖不同的选项。

     bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --create --topic <TopicName> --partitions <NumberOfPartitions> --replication-factor <ReplicationFactor> --config <Option1>=<Value1> --config <Option2>=<Value2>

     创建名为 的主题的命令示例 mytopic

     bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic mytopic --partitions 50 --replication-factor 3 --config cleanup.policy=compact --config min.insync.replicas=2

2. 使用 kafka-topics.sh 验证主题是否存在。

   bin/kafka-topics.sh --bootstrap-server <BrokerAddress> --describe --topic <TopicName>

   描述名为 的主题的命令示例 mytopic

   bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic mytopic