kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head
Date Wed, 28 May 2014 14:50:21 GMT
Any error from the controller/state-change log?

Thanks,

Jun


On Wed, May 28, 2014 at 1:50 AM, Hemath Kumar <hksrckmurthy@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 <wangguoz@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 <hksrckmurthy@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 <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
> > > >
> > >
> >
> >
> >
> > --
> > -- Guozhang
> >
>

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