Can you share your build depencies, notably the versions of Storm and storm-kafka and their respective artifactId and groupId? That is, the snippets relevant to storm-core and storm-kafka from your pom.xml, build.gradle, build.sbt, or similar build configuration file. Also, please add from which Maven repositories you are downloading storm-core and storm-kafka, respectively.
Best, Michael On 06/11/2014 09:52 PM, 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
