大家好,我正在尝试使用kafka主题命令行工具创建一个Kafka主题,但它仍然显示“命令的语法不正确”。我使用的是Kafka版本2.5.0 (提交:66563e712b0b9f84)下面是我尝试过的命令,但每次都收到相同的错误。
1. .\kafka-topics.bat --bootstrap-server broker:9092 --topic topic1 --create --replication-factor 1 --partitions 1
2. .\kafka-topics.bat --create --topic ngdev-topic --zookeeper localhost:2181 --replication-factor 1 --partitions 3
3. .\kafka-topics.bat -create -zookeeper localhost:2181 -replication-factor 1 -partitions 1 -topic sql-insert
4. .\kafka-topics.bat --bootstrap-server localhost:9092 --create --topic test1 --partitions 1 --replication-factor 1发布于 2021-02-20 22:05:35
该命令是kafka-topics --create,它具有子参数。图中所示的尝试3是最接近的,但对所有参数只使用一个破折号,而不是两个。
接下来,给主题命名为--topic X
然后,给出集群连接字符串,最好使用--bootstrap-server,因为Zookeeper标志已弃用
那么replication-factor是可选的,它将对所有主题使用server.properties文件中定义的值。partitions也是如此,但是设置它总是很好的
https://stackoverflow.com/questions/66292165
复制相似问题