草庐IT

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

血煞长虹 2023-04-18 原文

前言

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

[root@CentOS6 kafka_2.13-3.3.1]# bin/kafka-topics.sh --list --zookeeper-server kafkahost:9092
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper-server 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)
[root@CentOS6 kafka_2.13-3.3.1]#

解决方案

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

1、查看主题

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

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

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

2、创建主题

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

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

尾言

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

附注

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

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

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

UnrecognizedOptionExceptionldquoxffkafkaspanjava-zookeeperzookeeper

有关Kafka报错：Exception in thread “main“ joptsimple.UnrecognizedOptionException: zookeeper is not a recogn的更多相关文章

  1. 深度学习部署：Windows安装pycocotools报错解决方法 - 2

    深度学习部署：Windows安装pycocotools报错解决方法1.pycocotools库的简介2.pycocotools安装的坑3.解决办法更多Ai资讯：公主号AiCharm本系列是作者在跑一些深度学习实例时，遇到的各种各样的问题及解决办法，希望能够帮助到大家。ERROR:Commanderroredoutwithexitstatus1:'D:\Anaconda3\python.exe'-u-c'importsys,setuptools,tokenize;sys.argv[0]='"'"'C:\\Users\\46653\\AppData\\Local\\Temp\\pip-instal

  2. ruby-on-rails - 报错 - 在 Snow Leopard 上安装 RVM - 2

    我正在尝试在我的SnowLeopard10.6.8上安装RVM，方法是:\curl-Lhttps://get.rvm.io|bash-sstable--ruby我得到这个错误:InstallingRubyfromsourceto:/Users/Villa/.rvm/rubies/ruby-2.0.0-p0,thismaytakeawhiledependingonyourcpu(s)...ruby-2.0.0-p0-#downloadingruby-2.0.0-p0,thismaytakeawhiledependingonyourconnection...ruby-2.0.0-p0-#e

  3. ruby - 为什么在 IRB 中使用 Refinement 时得到 "main.using is permitted only at toplevel"？ - 2

    我尝试在IRB(v0.9.6，Ruby2.3.0)中使用Refinement:moduleFoorefineObjectdodeffoo()"foo"endendendusingFoo#=>RuntimeError:main.usingispermittedonlyattoplevel这基本上是theexactsetupfromthedocumentation(这会导致相同的错误)。出了什么问题？我该如何解决这个问题？ 最佳答案 这可能是IRb的错误或功能不当。众所周知，由于IRb的实现方式非常骇人听闻，因此它无法在所有极端情况下正

  4. Unity 报错No ‘git‘ executable was found. Please install Git on your system then restart - 2

    亲测可用。Anerroroccurredwhileresolvingpackages:Projecthasinvaliddependencies: com.unity.xxx:No'git'executablewasfound.PleaseinstallGitonyour  systemthenrestartUnityandUnityHub在我们使用PackageManager时，Unity允许我们使用Git上的package（点击加号，选择addpackagefromgitURL，或者是直接在Asset/Packages/manifest.json中添加包名）。但是这种操作需要我们事先装好g

  5. ruby - main :Object (NoMethodError) though method is defined 的未定义方法 - 2

    我已经使用以下代码片段定义了一个脚本:check_paramsparamdefcheck_params(param)#somecodeend当我运行它时，我得到了undefinedmethod`check_params'formain:Object(NoMethodError) 最佳答案 Ruby期望方法在你调用它之前被声明，尝试在你调用方法之前移动你的方法定义:defcheck_params(param)#somecodeendcheck_paramsparam 关于ruby-main

  6. ruby-on-rails - Rails/Ruby创建数据库报错: Unable to load the EventMachine C extension - 2

    更新:eventmachinegem已安装并在我的gemfile中:eventmachine(1.0.0,0.12.10)请帮忙!尝试使用以下内容创建数据库:Fitzs-MacBook-Pro:twilio_insanityFitz$rakedb:create'返回以下错误:UnabletoloadtheEventMachineCextension;Tousethepure-rubyreactor,require'em/pure_ruby'rakeaborted!cannotloadsuchfile--rubyeventmachine/Users/Fitz/.rvm/gems/ruby

  7. nginx配置https后报错nginx: [emerg] https protocol requires SSL support in XXX.conf详细解决方法 - 2

    一、前言最近，在测试环境的nginx里增加了一个https配置：location/api-meeting-qq/{proxy_passhttps://api.meeting.qq.com/;}然后，执行命令：//这个是nginx启动文件的路径，根据实际情况自行更改sudo/home/useradmin/nginx/sbin/nginx-sreload结果，nginx就报错了：nginx:[emerg]httpsprotocolrequiresSSLsupportin/home/useradmin/nginx/conf.d/trainNginx.conf:9二、解决方法百度发现，是之前安装ngi

  8. kafka如何动态消费新增topic主题 - 2

    一、解决痛点使用spring-kafka客户端，每次新增topic主题，都需要硬编码客户端并重新发布服务，操作麻烦耗时长。kafkaListener虽可以支持通配符消费topic，缺点是并发数需要手动改并且重启服务。对于业务逻辑相似场景，创建新主题动态监听可以用kafka-batch-starter组件二、组件能力1、新增topic名称为：auto.topic1（由于配置spring.kafka.consumer.prefix为auto，因此只有auto前缀的topic，才会被组件动态监听。）2、应用输出日志，监听到新增auto.topic1，并初始化客户端(主题刷新间隔为10s)3、发新的消

  9. css - Less.js LoadError - 没有这样的文件要加载 - less 在 main .less 文件上 - 2

    我正在尝试在一个新元素中测试less.js。我100%确定javascript文件加载正常，但我的css文件夹中的less文件一直出现此错误。我打算在启动之前使用less.app编译它，但我宁愿让less.js在开发期间进行编译。由于它是.less或其他文件而不允许浏览器访问该文件是否存在问题？谢谢(运行ubuntu11.04和ruby​​v1.9.2，在firefox和chrome中同样的错误)这是我的head.haml文件，我在其中链接到less.js和app.less(它们都在正确的文件夹中)%link{:rel=>"stylesheet/less",:type=>"text/c

  10. ruby - 如果 `main` 是 `Object` 的实例，为什么我不能调用它？ - 2

    当我输入self时，我得到一个返回值main。我做了这个测试:main2=Object.new然后我可以调用main2，它会返回一些东西，但是当我调用main时，它会引发一个undefinedvariable错误。这是怎么发生的？以下是我在其他网站上发现的关于这个顶级环境如何工作的假设:classObjectObject.new.instance_evaldodefself.to_s"main"endprivate###Yourprogramgetsinsertedhere...##endend这对我来说很有意义。 最佳答案 “Wh

随机推荐