Glad to know that. :)
On Thu, Sep 4, 2014 at 11:43 PM, Kushan Maskey < [email protected]> wrote: > 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 >> >> > -- 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
