Any error from the controller/state-change log? Thanks,
Jun On Wed, May 28, 2014 at 1:50 AM, Hemath Kumar <hksrckmur...@gmail.com>wrote: > even if i specify the topic its showing the same error. > > /opt/kafka_2.10-0.8.1.1/bin/kafka-run-class.sh > kafka.tools.ConsumerOffsetChecker -zkconnect localhost:2181 --group > group_name --topic testtopic > > > On Wed, May 28, 2014 at 10:42 AM, Guozhang Wang <wangg...@gmail.com> > wrote: > > > 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 > > >
