7.7. 创建主题

创建主题

1. 使用 kafka-topics.sh 工具创建一个主题，并指定以下内容：

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

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

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

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

     Copy to Clipboard Toggle word wrap

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

     /opt/kafka/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

     Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap

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

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

   Copy to Clipboard Toggle word wrap