java.lang.IllegalArgumentException kafka控制台消费者

作者: 雨儿
发布时间: 2024-12-13 01:47:12 (12天前)
转自：

3 条回复

0#
回复此人
1号 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 我遇到过同样的问题（的 错误/异常 </强> ）当运行消费者时。但是，情景略有不同。 我最初正在与之合作的 卡夫卡版 - 2.11-0.10.2.0（旧） </强> 然后我不得不改为的 2.10-0.9.0.1（新） </强> 。 所以当我下载了的 新 </强> 设置，刚开始 zookeeper，经纪人，制片人 最后是 消费者 我收到了上述错误。我正在使用下载中给出的默认生产者和消费者脚本，并测试快速入门指南。 <BLOCKQUOTE> 我得到了与上面相同的错误。我无法弄清楚新下载的包中的制作者如何使用不同的内容的 罐 </强> 正如上面的答案所解释的那样。 </BLOCKQUOTE> 所以，我意识到必须有一个共同的地方被我发现的所有Kafka实例引用的 的/ tmp /卡夫卡-日志 </强> 和的 的/ tmp /饲养员 </强> 文件夹。 一次，删除它们并重新启动我的的 新 </强> 下载Kafka实例，我能够摆脱上述异常，事情顺利进行。 希望这增加了帮助其他人也面临相同的错误，但在不同的情况下。 沙比尔 </DIV>

编辑
1#
回复此人
biu~额 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 我遇到了完全相同的问题。根本原因是kafka jar文件与您的kafka安装使用的文件与您用于开发和运行生产者的文件之间不兼容。您可以在/ usr / hdp / current / kafka-broker / libs中找到您的安装使用的kafka jar版本 在我的情况下，我的kafka安装使用的是kafka_2.10-0.9.0.2.4.2.0-258.jar，但我与我的生产商捆绑的kafka jar是0.10.0.1。有一次，我切换到0.9.0.2.4.2.0-258，它有效。 如果您的集群是HDP并且您正在使用maven来构建生产者，那么您可以在此处找到所有jar依赖项 <a href="http://repo.hortonworks.com/content/repositories/releases/" rel="nofollow"> http://repo.hortonworks.com/content/repositories/releases/ </A> 对于maven，这是你必须使用的： 库： <pre> <code> <repositories> <repository> <id>org.hortonworks</id> <url>http://repo.hortonworks.com/content/repositories/releases/</url> </repository> </repositories> </code> </pre> 相关性： <pre> <code> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.9.0.2.4.2.0-258</version> <scope>compile</scope> <exclusions> <exclusion> <artifactId>jmxri</artifactId> <groupId>com.sun.jmx</groupId> </exclusion> <exclusion> <artifactId>jms</artifactId> <groupId>javax.jms</groupId> </exclusion> <exclusion> <artifactId>jmxtools</artifactId> <groupId>com.sun.jdmk</groupId> </exclusion> </exclusions> </dependency> </code> </pre> </DIV>

编辑

登录后才能参与评论