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 <[email protected]> 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 <[email protected]> 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: [email protected]
> Website: http://www.tcs.com
> ____________________________________________
> Experience certainty. IT Services
> Business Solutions
> Consulting
> ________________________________________
>
> -----Deepak Sharma wrote: -----
> To: user <[email protected]>
> From: Deepak Sharma <[email protected]>
> 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 <[email protected]> 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
>
