Kafka报错：Exception in thread “main“ joptsimple.UnrecognizedOptionException: zookeeper is not a recogn

叁歲伎倆 2023-09-28 23:15 91阅读 0赞

前言

kafka版本过高所致，2.2+=的版本，已经不需要依赖zookeeper来查看/创建topic，新版本使用 --bootstrap-server替换老版本的 --zookeeper-server。

  1. [root@CentOS6 kafka_2.13-3.3.1]# bin/kafka-topics.sh --list --zookeeper-server kafkahost:9092
  2. Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper-server is not a recognized option
  3.         at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
  4.         at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
  5.         at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
  6.         at joptsimple.OptionParser.parse(OptionParser.java:396)
  7.         at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:567)
  8.         at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)
  9.         at kafka.admin.TopicCommand.main(TopicCommand.scala)
  10. [root@CentOS6 kafka_2.13-3.3.1]#

71f6c79e72c045aa94b5b56e0a91a50b.png

解决方案

把下面命令中的 --zookeeper-server替换为 --bootstrap-server就可以了，如下图所示：

1、查看主题

  1. bin/kafka-topics.sh --list --bootstrap-server kafkahost:9092

903beea29a7545dea6a78ee0221b32a5.png

注：上图中的kafkahost，是我自己在etc/host中配置的，可通过vim /etc/host去编辑

ad1872dd88894bfdbb57467a660db297.png

当然，你也可以通过ifconfig获取虚拟IP后，把kafkahost替换为虚拟IP。

2、创建主题

  1. bin/kafka-topics.sh --bootstrap-server kafkahost:9092 --create --topic talking --partitions 1
  3. bin/kafka-topics.sh --bootstrap-server kafkahost:9092 --list

8343e8e76d1e4af78febe9ee917319a7.png

尾言

时代在进步，版本在更迭，只有不断学习，才能感受时代的脚步，加油！

附注

1、ZK/Zookeeper的下载和安装 | 真/伪集群的快速搭建

2、Kafka锦集（一）：Kafka的安装和介绍，总结的很详细

3、配置Kafka的监听 | kafka启动报错：java.net.UnknownHostException

发表评论

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

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

相关阅读