kafka新建topic

在Kafka中，要创建一个新的主题（topic），可以使用`kafka-topics.sh`工具。以下是如何执行这个操作的基本步骤[^1]：

1. 打开终端并定位到包含`kafka-topics.sh`脚本的目录。
2. 使用以下命令列出当前可用的ZooKeeper服务器地址（假设是localhost:2181）：

   ./kafka-topics.sh --list --zookeeper localhost:2181

3. 调用`kafka-topics.sh`创建新主题，比如创建名为`topic1`的主题，设置分区数为3，复制因子（replication factor）为2：

   ./kafka-topics.sh --create --zookeeper localhost:2181 --topic topic1 --partitions 3 --replication-factor 2

这会创建一个新的topic，分区间的数据冗余由replication-factor决定，确保即使某个分区失败，数据仍能从其他副本恢复。