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

心已赠人 2024-03-22 11:34 118阅读 0赞

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

背景：

在kafka集群上使用topic相关的命令时，报错：

  1. Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
  2.     at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
  3.     at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
  4.     at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
  5.     at joptsimple.OptionParser.parse(OptionParser.java:396)
  6.     at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:567)
  7.     at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)
  8.     at kafka.admin.TopicCommand.main(TopicCommand.scala)

原因及解决方法：

这是因为安装的kafka版本过高，2.8+的kafka，已经不需要依赖zookeeper来创建topic，新版本使用 —bootstrap-server 参数，例：

  1. #创建主题
  2. ./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1
  4. #查看主题
  5. ./kafka-topics.sh --list --bootstrap-server localhost:9092

发表评论

表情：
评论列表 （有 0 条评论，118人围观）

还没有评论，来说两句吧...

相关阅读