Dear Michael,
I am using storm0.9.0.1 with kafka 0.8.1.1 and below mentioned are the
dependencies. I tried with both storm-kafka 0.9.2-incubating-SNAPSHOT
and storm-kafka-0.8-plus
0.4.0. The zookeeper version is 3.3.6.
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>0.9.1-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-kafka</artifactId>
<version>0.9.2-incubating-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>net.wurstmeister.storm</groupId>
<artifactId>storm-kafka-0.8-plus</artifactId>
<version>0.4.0</version>
</dependency>
Regards
Anis
On Wed, Jun 11, 2014 at 10:51 PM, Michael G. Noll <
[email protected]> wrote:
> 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
>
>
