Re: Kafka-Storm Run-time Exception

, Jun 5, 2014 at 4:40 PM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: I am using kafka with storm. I am using maven to build my topology and I am using scala 2.9.2 same as I am using kafka_2.9.2_0.8.1. Topology build perfectly using maven. But hwn I submit the topology

Re: Unable to build kafka.

/ On Jun 4, 2014, at 8:07 PM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: I followed the readme for kafka-0.8.0. After I am getting the following warnings ./sbt assembly-package-dependency [info] Loading project definition from /home/abhishek/Project/kafka

Re: Unable to build kafka.

://www.twitter.com/allthingshadoop / On Thu, Jun 5, 2014 at 4:25 AM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: Thanks for the reply. I re built kafka. And now when I am running server it is stopping saying it cannot find

Re: Unable to build kafka.

://www.stealth.ly Twitter: @allthingshadoop http://www.twitter.com/allthingshadoop / On Thu, Jun 5, 2014 at 8:16 AM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: I have a project running on kafka.0.8.0. Are there any changes

Kafka-Storm Run-time Exception

is appreciated ! Thanks -- *Abhishek Bhattacharjee* *Pune Institute of Computer Technology*

Unable to build kafka.

. The server runs but data doesn't go in. LeaderNotAvailableException is raised. Thanks -- *Abhishek Bhattacharjee* *Pune Institute of Computer Technology*

[Keeping equal no of messages in partitions ]

I want to store equal no.of messages in partitions. For eg. if I have 100 messages and 2 partitions for a topic then each partition should have 50 messages. Can someone help me with this I am new to kafka so any help will be appreciated. Thanks, -- *Abhishek Bhattacharjee* *Pune Institute

[Using offset to fetch message][Need Help]

that message(only that message). Thanks, *Abhishek Bhattacharjee* *Pune Institute of Computer Technology*

Re: [Using offset to fetch message][Need Help]

guarantees to call the *fail* and *ack* methods with the *messageId* on the exact same spout that the message originated from. This means if you have cached the message there then it will still be available. On 27 January 2014 19:29, Abhishek Bhattacharjee abhishek.bhattacharje

Re: [Consumer code not working][Kafka Newbie]

? https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Myconsumerseemstohavestopped,why ? Thanks, Jun On Mon, Jan 20, 2014 at 7:22 AM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: Sorry I have sent both codes as consumer codes. This is the producer code

Re: [Consumer code not working][Kafka Newbie]

, Jan 21, 2014 at 8:02 AM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: I read the faqs and I added auto.offset.reset property in the configuration setting of storm. Then I ran my producer code and then I ran my consumer code when I ran the consumer code it printed all

[Consumer code not working][Kafka Newbie]

().message())); } } Thanks. -- *Abhishek Bhattacharjee* *Pune Institute of Computer Technology*

Re: [Consumer code not working][Kafka Newbie]

, Jan 20, 2014 at 8:46 PM, Abhishek Bhattacharjee abhishek.bhattacharje...@gmail.com wrote: Hello, I am new to kafka and facing some problem. My producer code works properly and sends data. But the consumer is not able to read it. Here are the codes for Producer and Consumer. Something is wrong