Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-28 Thread Jun Rao
hen 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. > > > > > > > > >

Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-28 Thread Hemath Kumar
tting 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

Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-27 Thread Guozhang Wang
> > > > 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.UnsupportedOperati

Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-27 Thread Hemath Kumar
heck > 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 c

Re: Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-27 Thread Guozhang Wang
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.Unsupp

Exception in thread "main" java.lang.UnsupportedOperationException: empty.head

2014-05-27 Thread Hemath Kumar
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(ConsumerOffsetChe