kafka创建一个 topic(主题/分片)

让我们创建一个名为“test”的topic，它有一个分区和一个副本：

1

> ./kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

现在我们可以运行list（列表）命令来查看这个topic：

1

2

> ./kafka-topics.bat --list --zookeeper localhost:2181

test

或者，您也可将代理配置为：在发布的topic不存在时，自动创建topic，而不是手动创建。