kafka集群创建topic
时间: 2023-09-10 21:11:19 浏览: 102
kafka集群搭建
要在Kafka集群中创建一个主题,可以使用kafka-topics.sh脚本。以下是创建一个名为"my_topic",具有3个分区和3个副本的命令示例:
```
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic my_topic
```
其中:
- `--create`:指定创建主题操作。
- `--zookeeper`:指定ZooKeeper连接字符串。
- `--replication-factor`:指定主题的副本数。
- `--partitions`:指定主题的分区数。
- `--topic`:指定主题名称。
这将在Kafka集群中创建一个名为"my_topic"的主题,该主题将具有3个分区和3个副本。您可以根据需要更改这些值。
阅读全文