大数据架构：flume-ng+Kafka+Storm+HDFS 实时系统组合

shareshow · 发表于 2015-11-11 15:21:35

按你的代码报错
.ClassNotFoundException: com.netflix.curator.RetryPolicy

大牛我这个是缺哪个包啊。。。百度云里的都导入到storm了啊还有能不能详细讲解一下topology的东西啊

shareshow · 发表于 2015-11-12 23:32:09

哪位大神帮我看看这个是什么错啊
Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequest
at storm.kafka.KafkaConfig.<init>(KafkaConfig.java:22)
at storm.kafka.SpoutConfig.<init>(SpoutConfig.java:15)
at com.storm.topology.MyTopology.main(MyTopology.java:24)
Caused by: java.lang.ClassNotFoundException: kafka.api.OffsetRequest
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)
... 3 more

lancijk · 发表于 2015-11-23 14:58:20

感谢楼主分享. 果然各种强大的存在.

skyhackvip · 发表于 2015-11-28 22:17:52

Exception in thread "main" java.lang.NoSuchMethodError: storm.kafka.SpoutConfig.forceStartOffsetTime(J)V
at com.storm.topology.MyTopology.main(MyTopology.java:28)