kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hemath Kumar <hksrckmur...@gmail.com>
Subject Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head
Date Wed, 28 May 2014 04:53:12 GMT
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 <wangguoz@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 <hksrckmurthy@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message