我试图把Apache风暴和Kafka结合起来。当我运行代码的时候,我得到了喷口和螺栓的创建。当我点击喷口时,在“错误”选项卡中出现以下错误:
java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy
at storm.kafka.KafkaSpout.open(KafkaSpout.java:68)
at backtype.storm.daemon.executor$fn__4949$fn__4964.invoke(executor.clj:542)
at backtype.storm.util$async_loop$fn__452.invoke(util.clj:463)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: org.apache.curator.RetryPolicy
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:358) ... 5 more
我正在使用hortonworks的sandboxvm,我尝试复制storm的lib文件夹中的curatortest、client和framworks(都是2.4.0)版本,但是问题仍然存在。
谢谢。
1条答案
按热度按时间vojdkbi01#
您的类路径中没有curator客户机jar,请查看此链接
https://github.com/abhinavg6/kafka-storm-conscomp/issues/1