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
