Thank you very much Michael.I downgraded to the older version (0.3.0) of wurstmeister's code that was using curator-framework 1.0.1. It is working for me now.
Cheers, Anis On Sat, Jun 14, 2014 at 11:15 PM, Michael G. Noll < [email protected]> wrote: > You may consider trying the build setup (dependencies as well as > excludes) in kafka-storm-starter until Storm 0.9.2 -- which includes > storm-kafka 0.9.2 -- is released. > > https://github.com/miguno/kafka-storm-starter/blob/develop/build.sbt > > Here I am using a re-packaged version of wurstmeister's spout. The > repackaged version is built against Java 6 and uses the latest version > of wurstmeister's code, i.e. it's newer than the last 0.4 version > released by wurstmeister. > > Details here: > https://clojars.org/com.miguno/storm-kafka-0.8-plus_2.10 > https://github.com/miguno/storm-kafka-0.8-plus/tree/miguno_clojars > > <dependency> > <groupId>com.miguno</groupId> > <artifactId>storm-kafka-0.8-plus_2.10</artifactId> > <version>0.5.0-SNAPSHOT</version> > </dependency> > > Again, I consider this as a short-term workaround until Storm 0.9.2 is > released. > > Hope this helps, > Michael > > > On 06/12/2014 12:58 PM, Anis Nasir wrote: > > I am still stuck on this issue. Can someone please help in upgrading the > > storm cluster 0.9.0.1 to use curator-framework 1.3.3 and zookeeper 3.4.5 > > > > Regards > > Anis > > > > > > On Wed, Jun 11, 2014 at 11:38 PM, Anis Nasir <[email protected] > > <mailto:[email protected]>> wrote: > > > > Regarding, 0.9.2-incubating-SNAPSHOT, it comes with the interface > > ILocalCluster. I can not find any example using it. > > > > Regards > > Anis > > > > > > On Wed, Jun 11, 2014 at 11:14 PM, Anis Nasir <[email protected] > > <mailto:[email protected]>> wrote: > > > > Dear Jonas, > > > > I am getting the same exception running this build > > > > https://github.com/wurstmeister/storm-kafka-0.8-plus-test > > > > > > > > Regards > > Anis > > > > > > On Wed, Jun 11, 2014 at 11:07 PM, János Háber > > <[email protected] > > <mailto:[email protected]>> wrote: > > > > Anis: no, you using snapshot version of storm-kafka plugin > > plus the old storm kafka plugin with storm 0.9.1... > > I think storm-kafka 0.9.2-incubating-SNAPSHOT only > > compatible with storm-core 0.9.2-incubating-SNAPSHOT > > > > In the 0.9.2-incubating-SNAPSHOT old curator framework > > (1.0.1) will be changed to more recent version... > > > > as you see you using two version of storm-kafka. Remove the > > old one (the 0.4.0 version) and increase the storm-core > > version to 0.9.2-incubating-SNAPSHOT... > > > > maybe it's help... > > > > b0c1 > > > > János Háber > > Fine Solution Ltd > > > > > > > > On Wed, Jun 11, 2014 at 11:03 PM, Anis Nasir > > <[email protected] <mailto:[email protected]>> wrote: > > > > 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] > > <mailto:[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 > > > > > > > > > > > > > >
