java.lang.ClassNotFoundException:kafka.api.OffsetRequest [英] java.lang.ClassNotFoundException: kafka.api.OffsetRequest
本文介绍了java.lang.ClassNotFoundException:kafka.api.OffsetRequest的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
在尝试将Kafka集成到我们的Storm拓扑时,出现java.lang.ClassNotFoundException kafka.api.OffsetRequest错误. 您正在运行什么版本并且正在运行? 我的pom.xml
I am getting error java.lang.ClassNotFoundException kafka.api.OffsetRequest while trying integrate Kafka to our Storm topology. What versions you are running and it is working? My pom.xml
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>0.9.2-incubating</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-kafka</artifactId>
<version>0.9.2-incubating</version>
</dependency>
推荐答案
最后,我通过以下方式实现了我自己的Kafka SPOUT(重用示例代码)来解决了这个问题:
Finally I solved it by implementing my own Kafka SPOUT (reusing example code) with this dependencies:
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>0.9.4</version>
</dependency>
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.9.2</artifactId>
<version>0.8.1.1</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>
这篇关于java.lang.ClassNotFoundException:kafka.api.OffsetRequest的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文