7.7. 创建主题
使用 kafka-topics.sh 工具管理主题。kafka-topics.sh 是 Apache Kafka 发行版本的 Streams 的一部分，可在 bin 目录中找到。
先决条件
- 每个主机上安装了 Apache Kafka 的流，且配置文件可用。
创建主题
使用
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>
创建名为
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
-
在
验证主题是否使用
kafka-topics.sh是否存在。/opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_address> --describe --topic <TopicName>
描述名为
mytopic的主题的命令示例/opt/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic mytopic
