Hi, I have downloaded the storm-kafka jar from the below link: http://repo1.maven.org/maven2/com/n3twork/storm/storm-kafka/20140521/
Now I have made changes in the storm word count topology and used KafkaSpout. While running topology in Local mode I get following error: java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy at storm.kafka.KafkaSpout.open(KafkaSpout.java:85) ~[storm-kafka-20140521.jar:na] at backtype.storm.daemon.executor$eval5100$fn__5101$fn__5116.invoke(executor.clj:519) ~[na:na] at backtype.storm.util$async_loop$fn__390.invoke(util.clj:431) ~[na:na] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na] at java.lang.Thread.run(Thread.java:636) [na:1.6.0_17] Caused by: java.lang.ClassNotFoundException: org.apache.curator.RetryPolicy at java.net.URLClassLoader$1.run(URLClassLoader.java:217) ~[na:1.6.0_17] at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_17] at java.net.URLClassLoader.findClass(URLClassLoader.java:205) ~[na:1.6.0_17] at java.lang.ClassLoader.loadClass(ClassLoader.java:319) ~[na:1.6.0_17] at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.6.0_17] at java.lang.ClassLoader.loadClass(ClassLoader.java:264) ~[na:1.6.0_17] at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:332) ~[na:1.6.0_17] Though the curator-client-1.0.1.jar is present in the lib of storm and I have included same in my buildpath. Thanks and Regards, Komal Thombare -----Andres Gomez wrote: ----- To: user@storm.incubator.apache.org From: Andres Gomez <andresgome...@gmail.com> Date: 06/02/2014 02:33PM Subject: Re: Storm-kafka Integration You should make a clone of this project: https://github.com/apache/incubator-storm/tree/master/external/storm-kafka and do “mvn install”, I suposse you use kafka 0.8.+ and then you do this: SpoutConfig spoutConfig = new SpoutConfig(); spoutConfig.zkServers = “localhost”; //zookeeper Host spoutConfig.zkPort = 2181; //zookeeper port spoutConfig.zkRoot = “/kafkaStorm/“; // zookeeper path spoutConfig.id = “storm”; // zookeeper id // This config is a example!! KafkaSpout spout = new KafkaSpout(spoutConfig); El 02/06/2014, a las 10:56, Joe Stein <joe.st...@stealth.ly> escribió: Please take a look at http://www.michael-noll.com/blog/2014/05/27/kafka-storm-integration-example-tutorial/#state-of-the-integration-game There is a github project too https://github.com/miguno/kafka-storm-starter This covers latest Storm, Kafka and Avro. /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop ********************************************/ On Mon, Jun 2, 2014 at 4:55 AM, Komal Thombare <komal.thomb...@tcs.com> wrote: Hi Deepak, Yes i have. I have also got the storm-contrib source code, but then I am unaware of how to compile it. Thanks and Regards, Komal Thombare Tata Consultancy Services Limited Ph:- 086-55388772 Mail-to: komal.thomb...@tcs.com Website: http://www.tcs.com ____________________________________________ Experience certainty. IT Services Business Solutions Consulting ________________________________________ -----Deepak Sharma wrote: ----- To: user <user@storm.incubator.apache.org> From: Deepak Sharma <deepakmc...@gmail.com> Date: 06/02/2014 02:22PM Subject: Re: Storm-kafka Integration Hi Komal Have you looked at KafkaSpout? Thanks Deepak On Mon, Jun 2, 2014 at 2:13 PM, Komal Thombare <komal.thomb...@tcs.com> wrote: Hi, I am trying to integrate storm with kafka, but did not get any proper documentation to do so. Can anyone please help me for getting started with the integration. Thanks and Regards, Komal Thombare =====-----=====-----===== Notice: The information contained in this e-mail message and/or attachments to it may contain confidential or privileged information. If you are not the intended recipient, any dissemination, use, review, distribution, printing or copying of the information contained in this e-mail message and/or attachments to it are strictly prohibited. If you have received this communication in error, please notify us by reply e-mail or telephone and immediately and permanently delete the message and any attachments. Thank you -- Thanks Deepak www.bigdatabig.com www.keosha.net
