这个错误通常是由于使用了错误的命令参数导致的。在Kafka的最新版本中,ZooKeeper已经被替换为使用Apache Kafka自己的内置元数据存储。因此,不再需要使用--zookeeper参数。

正确的命令应该是:

kafka-topics.sh --create --bootstrap-server <bootstrap-server> --topic <topic-name> --partitions <num-partitions> --replication-factor <replication-factor>

其中,<bootstrap-server>是Kafka集群的引导服务器地址,<topic-name>是要创建的主题名称,<num-partitions>是主题的分区数,<replication-factor>是主题的副本因子。

请注意,确保使用正确的命令参数和值,并根据你的Kafka版本进行相应的调整。

kafka创建主题失败如下错误:Exception in thread main joptsimpleUnrecognizedOptionException zookeeper is not a recognized option

原文地址: http://www.cveoy.top/t/topic/h9Jx 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录