kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Inder Pall <inder.p...@gmail.com>
Subject Re: exception in server...
Date Mon, 24 Oct 2011 05:32:00 GMT
Thanks Jun, unfortunately it's not very descriptive for new folks who don't
have enough context as to why consumer would look for an offset which isn't
in ZK.

- Inder

On Sun, Oct 23, 2011 at 10:26 PM, Jun Rao <junrao@gmail.com> wrote:

> This has been fixed in https://issues.apache.org/jira/browse/KAFKA-89
>
> Jun
>
> On Sun, Oct 23, 2011 at 10:18 PM, Inder Pall <inder.pall@gmail.com> wrote:
>
> > once in a while i keep seeing the following.... though i don't see any
> > messages getting lost.
> > usually happens when the server comes up..
> >
> > ROR error when processing request topic:revenuefeed, part:1
> > offset:9223372036854775807 maxSize:307200
> > kafka.common.OffsetOutOfRangeException: offset 9223372036854775807 is out
> > of
> > rangekafka.common.OffsetOutOfRangeException: offset 9223372036854775807
> is
> > out of range
> >        at kafka.log.Log$.findRange(Log.scala:47)
> >        at kafka.log.Log.read(Log.scala:223)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers.kafka$server$KafkaRequestHandlers$$readMessageSet(KafkaRequestHandlers.scala:124)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$3.apply(KafkaRequestHandlers.scala:115)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$3.apply(KafkaRequestHandlers.scala:114)
> >        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.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
> >        at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
> >        at
> > scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
> >        at scala.collection.mutable.ArrayOps.map(ArrayOps.scala:34)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers.handleMultiFetchRequest(KafkaRequestHandlers.scala:114)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$3.apply(KafkaRequestHandlers.scala:43)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$3.apply(KafkaRequestHandlers.scala:43)
> >        at kafka.network.Processor.handle(SocketServer.scala:268)
> >        at kafka.network.Processor.read(SocketServer.scala:291)
> >        at kafka.network.Processor.run(SocketServer.scala:202)
> >        at java.lang.Thread.run(Thread.java:662)
> >  (kafka.server.KafkaRequestHandlers)
> > [2011-10-23 22:12:24,844] ERROR error when processing request
> > topic:revenuefeed, part:0 offset:9223372036854775807 maxSize:307200
> > kafka.common.OffsetOutOfRangeException: offset 9223372036854775807 is out
> > of
> > rangekafka.common.OffsetOutOfRangeException: offset 9223372036854775807
> is
> > out of range
> >        at kafka.log.Log$.findRange(Log.scala:47)
> >        at kafka.log.Log.read(Log.scala:223)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers.kafka$server$KafkaRequestHandlers$$readMessageSet(KafkaRequestHandlers.scala:124)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$3.apply(KafkaRequestHandlers.scala:115)
> >        at
> >
> >
> kafka.server.KafkaRequestHandlers$$anonfun$3.apply(KafkaRequestHandlers.scala:114)
> >
> >
> >
> > -- Inder
> >
>



-- 
-- Inder

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message