Thank you. I actually cleared all the zookeeper/version-2/* folders and now its all working fine. Thanks a lot.
-- Kushan Maskey 817.403.7500 On Thu, Sep 4, 2014 at 1:05 PM, Vikas Agarwal <[email protected]> wrote: > Delete (better would be keep backup) the version-2 directory from > zookeeper data directory (see zoo.cfg for data dir location). You can > reference > http://stackoverflow.com/questions/22982919/wiping-out-the-zookeeper-data-directory > > > On Thu, Sep 4, 2014 at 9:44 PM, Kushan Maskey < > [email protected]> wrote: > >> Which zookeeper data do I need to delete? Storm or Kafka? >> >> -- >> Kushan Maskey >> 817.403.7500 >> >> >> On Thu, Sep 4, 2014 at 11:01 AM, Vikas Agarwal <[email protected]> >> wrote: >> >>> I guess, you need to empty the zookeeper data directory too. >>> >>> >>> On Thu, Sep 4, 2014 at 9:22 PM, Kushan Maskey < >>> [email protected]> wrote: >>> >>>> I had to manually flush all the data from kafka. I did that by stopping >>>> the server and deleting the entire content of kafka-logs directory. Then I >>>> restarted kafka again. Then I started my storm. I get following error >>>> message. Because the offset KafkaSpout is looking for is at 81573 and kafka >>>> offset is at 0 right now. How do i resolve this problem? >>>> >>>> kafka.common.OffsetOutOfRangeException: Request for offset 81573 but we >>>> only have log segments in the range 0 to 0. >>>> >>>> at kafka.log.Log.read(Log.scala:380) >>>> >>>> at >>>> kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:530) >>>> >>>> at >>>> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:476) >>>> >>>> at >>>> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:471) >>>> >>>> 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:471) >>>> >>>> at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:437) >>>> >>>> at kafka.server.KafkaApis.handle(KafkaApis.scala:186) >>>> >>>> at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) >>>> >>>> at java.lang.Thread.run(Thread.java:744) >>>> >>>> [2014-09-04 15:35:25,904] ERROR [KafkaApi-0] Error when processing >>>> fetch request for partition [1002,0] offset 8430 from consumer with >>>> correlation id 0 (kafka.server.KafkaApis) >>>> >>>> kafka.common.OffsetOutOfRangeException: Request for offset 8430 but we >>>> only have log segments in the range 0 to 0. >>>> >>>> at kafka.log.Log.read(Log.scala:380) >>>> >>>> at >>>> kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSet(KafkaApis.scala:530) >>>> >>>> at >>>> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:476) >>>> >>>> at >>>> kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(KafkaApis.scala:471) >>>> >>>> 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:471) >>>> >>>> at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:437) >>>> >>>> at kafka.server.KafkaApis.handle(KafkaApis.scala:186) >>>> >>>> at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) >>>> >>>> at java.lang.Thread.run(Thread.java:744) >>>> -- >>>> Kushan Maskey >>>> >>>> >>> >>> >>> -- >>> Regards, >>> Vikas Agarwal >>> 91 – 9928301411 >>> >>> InfoObjects, Inc. >>> Execution Matters >>> http://www.infoobjects.com >>> 2041 Mission College Boulevard, #280 >>> Santa Clara, CA 95054 >>> +1 (408) 988-2000 Work >>> +1 (408) 716-2726 Fax >>> >>> >> > > > -- > Regards, > Vikas Agarwal > 91 – 9928301411 > > InfoObjects, Inc. > Execution Matters > http://www.infoobjects.com > 2041 Mission College Boulevard, #280 > Santa Clara, CA 95054 > +1 (408) 988-2000 Work > +1 (408) 716-2726 Fax > >
