Could you tell me how to run DumpLogSegment?
Thanks, Nalin On Wed, Nov 2, 2011 at 6:19 PM, Jun Rao <jun...@gmail.com> wrote: > I don't see the attached log file. I guess the Apache mailing list doesn't > really allow attachments. Could you run the util DumpLogSegement? It will > tell you whether the log file is corrupted or not. > > Thanks, > > Jun > > On Wed, Nov 2, 2011 at 3:54 PM, Nalin DeZoysa <ndezo...@tagged.com> wrote: > > > Hi, > > > > I'm seeing that certain topics get corrupted - I can publish to it, but > > when I try and subscribe to a topic, the response that comes back has > > header error code 1. I also see this exception being thrown by Kafka. > > > > [2011-11-02 15:36:40,947] ERROR error when processing request > > topic:cards_card_251791, part:0 offset:281474976724790 maxSize:1048576 > > (kafka.server.KafkaRequestHandlers) > > kafka.common.OffsetOutOfRangeException: offset 281474976724790 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.handleFetchRequest(KafkaRequestHandlers.scala:107) > > at > > > kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$2.apply(KafkaRequestHandlers.scala:42) > > at > > > kafka.server.KafkaRequestHandlers$$anonfun$handlerFor$2.apply(KafkaRequestHandlers.scala:42) > > 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:619) > > > > > > > > I have attached the log file for the topic. > > > > Is there a way to work around this issue? > > > > > > Thanks, > > Nalin > > >
