I got something similar, do not remember what exactly i did as it was quite a simple. check curator libs you are compiling in your code and libs which is storm installation libs. Probably kafka lib you downloaded was used with different version of curator. Actually I've checked out storm incubation project and build everything by myself, with slightly modified dependencies. I can be wrong, but If I remember right, I launched some mvn target from storm-dist/binary directory.
On 11 June 2014 21:18, János Háber <[email protected]> wrote: > Yeah... this is one of the biggest problem of about kafka <-> storm > integration (second is the kafka-storm module scala dependency version, but > I explain this in another topic), and this is why I plan move to Spark... > ok it's only near real time, but more stable than Storm (and native can run > on hadoop yarn) > > János Háber > Fine Solution Ltd > > > > On Wed, Jun 11, 2014 at 9:59 PM, Derek Dagit <[email protected]> wrote: > >> Looks like a curator version mismatch... >> >> -- >> Derek >> >> >> On 6/11/14, 14:52, Anis Nasir wrote: >> >>> Dear all, >>> >>> >>> I am getting below mentioned exception while running storm-kafka. Does >>> anyone have seen this one before? >>> >>> >>> 7800 [Thread-27-words] ERROR backtype.storm.util - Async loop died! >>> java.lang.NoSuchMethodError: com.netflix.curator.framework. >>> api.CreateBuilder.creatingParentsIfNeeded()Lcom/ >>> netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable; >>> at storm.kafka.ZkState.writeBytes(ZkState.java:59) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.ZkState.writeJSON(ZkState.java:53) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.PartitionManager.commit(PartitionManager.java:188) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at backtype.storm.daemon.executor$fn__3430$fn__3445$fn_ >>> _3474.invoke(executor.clj:547) >>> ~[storm-core-0.9.0.1.jar:na] >>> at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) >>> ~[storm-core-0.9.0.1.jar:na] >>> at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.4.0.jar:na] >>> at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_30] >>> 7800 [Thread-27-words] ERROR backtype.storm.daemon.executor - >>> java.lang.NoSuchMethodError: com.netflix.curator.framework. >>> api.CreateBuilder.creatingParentsIfNeeded()Lcom/ >>> netflix/curator/framework/api/ProtectACLCreateModePathAndBytesable; >>> at storm.kafka.ZkState.writeBytes(ZkState.java:59) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.ZkState.writeJSON(ZkState.java:53) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.PartitionManager.commit(PartitionManager.java:188) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.KafkaSpout.commit(KafkaSpout.java:169) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:134) >>> ~[storm-kafka-0.8-plus-0.5.0-SNAPSHOT.jar:na] >>> at backtype.storm.daemon.executor$fn__3430$fn__3445$fn_ >>> _3474.invoke(executor.clj:547) >>> ~[storm-core-0.9.0.1.jar:na] >>> at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) >>> ~[storm-core-0.9.0.1.jar:na] >>> at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.4.0.jar:na] >>> at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_30] >>> >>> Regards >>> Anis >>> >>> >
