OffsetoutofRange Exception

[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
available.

I see the below exception continuously in kafka server log. Any information
is greatly appreciated.

Thanks !


[2014-02-24 02:12:20,832] ERROR [KafkaApi-0] Error when processing fetch
request for partition [asdaGro,0] offset 1318 from consumer with
correlation id 0 (kafka.server.KafkaApis)
kafka.common.OffsetOutOfRangeException: Request for offset 1318 but we only
have log segments in the range 0 to 2.
        at kafka.log.Log.read(Log.scala:429)
        at
kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388)
        at
kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334)
        at
kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
        at
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
        at scala.collection.immutable.Map$Map1.map(Map.scala:93)
        at
kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330)
        at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:66)
        at
kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
        at java.lang.Thread.run(Thread.java:724)
[2014-02-24 02:12:21,833] ERROR [KafkaApi-0] Error when processing fetch
request for partition [asdaGro,0] offset 1318 from consumer with
correlation id 0 (kafka.server.KafkaApis)
kafka.common.OffsetOutOfRangeException: Request for offset 1318 but we only
have log segments in the range 0 to 2.
        at kafka.log.Log.read(Log.scala:429)
        at
kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:388)
        at
kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:334)
        at
kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:330)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
        at
scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
        at scala.collection.immutable.Map$Map1.map(Map.scala:93)
        at
kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(KafkaApis.scala:330)
        at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:296)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:66)
        at
kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
        at java.lang.Thread.run(Thread.java:724)