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 08:50:00 GMT
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