Hemath, I will need more info to check the reasons kafka stopped working. For consumer offset checker tool, you need to specify the topic names, otherwise you will see "empty.head".
Guozhang On Tue, May 27, 2014 at 9:53 PM, Hemath Kumar <hksrckmur...@gmail.com> wrote: > This is the command i have used. > > ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect > localhost:2181 --group consumer_group > > > Not just only error with this command. when this sitution occured messages > are not able to produce and consumer any more. > > > On Tue, May 27, 2014 at 9:22 PM, Guozhang Wang <wangg...@gmail.com> wrote: > > > Hi, > > > > Could you print the full command line you used consumer offset checker > > tool? > > > > Guozhang > > > > > > On Tue, May 27, 2014 at 12:46 AM, Hemath Kumar <hksrckmur...@gmail.com> > > wrote: > > > > > Every time when i reboot my machine kafka is not working. when i check > > the > > > consumeroffset tool i am getting this error. I am new to this i could > > not > > > figure out what could be the issues. > > > > > > I am saving the logs in /data/zk and /data/kafka. And its running on > > single > > > node. Would appriciate if any one could help me in this regard. > > > > > > > > > > > > > > > > > > Exception in thread "main" java.lang.UnsupportedOperationException: > > > empty.head > > > at scala.collection.immutable.Vector.head(Vector.scala:192) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$.kafka$tools$ConsumerOffsetChecker$$processPartition(ConsumerOffsetChecker.scala:72) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$$anonfun$kafka$tools$ConsumerOffsetChecker$$processTopic$1.apply$mcVI$sp(ConsumerOffsetChecker.scala:89) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$$anonfun$kafka$tools$ConsumerOffsetChecker$$processTopic$1.apply(ConsumerOffsetChecker.scala:89) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$$anonfun$kafka$tools$ConsumerOffsetChecker$$processTopic$1.apply(ConsumerOffsetChecker.scala:89) > > > at > > > > > > > > > scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) > > > at > scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$.kafka$tools$ConsumerOffsetChecker$$processTopic(ConsumerOffsetChecker.scala:88) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$$anonfun$main$3.apply(ConsumerOffsetChecker.scala:153) > > > at > > > > > > > > > kafka.tools.ConsumerOffsetChecker$$anonfun$main$3.apply(ConsumerOffsetChecker.scala:153) > > > at scala.collection.immutable.List.foreach(List.scala:318) > > > at > > > > kafka.tools.ConsumerOffsetChecker$.main(ConsumerOffsetChecker.scala:152) > > > at > > kafka.tools.ConsumerOffsetChecker.main(ConsumerOffsetChecker.scala) > > > > > > > > > > > -- > > -- Guozhang > > > -- -- Guozhang
