bin/kafka-run-class.sh kafka.tools.DumpLogSegments logfilename -noprint Jun
On Thu, Nov 3, 2011 at 11:33 AM, Nalin DeZoysa <ndezo...@tagged.com> wrote: > 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 > > > > > >
