kafka启动创建topic报错:zookeeper is not a recognized option

  • Post author:
  • Post category:其他


当前使用版本:kafka_2.13-3.4.0



使用老版本的创建topic的命令,是用




zookeeper




来创建,但是报错如下

D:\Software\Doument\kafka_2.13-3.4.0> .\bin\windows\kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test


Exception in thread “main” joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option

at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)

at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)

at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)

at joptsimple.OptionParser.parse(OptionParser.java:396)

at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:567)

at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)

at kafka.admin.TopicCommand.main(TopicCommand.scala)




这是新版本创建topic的命令,localhost:9092是kafka的 启动地址:端口

D:\Software\Doument\kafka_2.13-3.4.0> .\bin\windows\kafka-topics.bat –create –bootstrap-server localhost:9092 –replication-factor 1 –partitions 1 –topic test



Created topic test.

这样问题就解决了



版权声明:本文为weishuai528原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。