Re: OffsetoutofRange Exception

2014-02-24 Thread Jun Rao
I am not sure how your plugin works. Does it use SimpleConsumer or the high level consumer? Which version of Kafka is it on? Thanks, Jun On Mon, Feb 24, 2014 at 12:28 PM, Krishna Raj wrote: > Hi Jun, > > I have exactly 2 messages when I run the console consumer. I am totally > confused why my

Re: OffsetoutofRange Exception

2014-02-24 Thread Krishna Raj
Hi Jun, I have exactly 2 messages when I run the console consumer. I am totally confused why my API Consumer looks for 1318 offset. Any help is greatly appreciated ! Thanks, KR On Mon, Feb 24, 2014 at 7:37 AM, Jun Rao wrote: > The following log says there are only 2 messages in the log. > >

Re: OffsetoutofRange Exception

2014-02-24 Thread Jun Rao
The following log says there are only 2 messages in the log. kafka.common.OffsetOutOfRangeException: Request for offset 1318 but we only have log segments in the range 0 to 2. If you run console consumer on that topic (using --from-beginning), how many messages do you see? Thanks, Jun On Mon,

OffsetoutofRange Exception

2014-02-24 Thread Krishna Raj
Hi there, I am a newbie to Kafka. I am trying to use the ( https://github.com/endgameinc/elasticsearch-river-kafka) plugin to pull the messages from Kafka. When I start the ElasticSearch, the 1st message gets pulled into the cluster. And after no messages are pulled even there are enough messages