I have seen those exceptions when you restart your Kafka client before the
configured Zookeeper session timeout has occured.
Try and wait a bit longer between client restarts (we wait for 40s) and see
if those exceptions go away.

On Tuesday, March 12, 2013, Dragos Manolescu wrote:

> Hi --
>
> I have a Scala Kafka consumer, written in the image of the Java code from
> the Quickstart doc. I use the consumer for prototyping and debugging so I
> start and stop it quite frequently. I noticed that every now and then, upon
> starting the consumer, a ConsumerRebalanceFailedException is thrown (see
> below). What's causing the problem this exception is signaling and what are
> the recommended practices for avoiding it? I am using Kafka 0.7.2 that I
> built with Scala 2.9.2.
>
> Thanks,
>
> -Dragos
>
> Exception in thread "main" kafka.common.ConsumerRebalanceFailedException:
> Kconsumer-group_mseac02jh0rjdkq4-1363106041719-5b75c065 can't rebalance
> after 4 retries
> at
> kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:473)
> at
> kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733)
> at
> kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207)
> at
> kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:137)
> at
> com.servicenow.syseng.kafka.KConsumer$delayedInit$body.apply(KConsumer.scala:69)
> at scala.Function0$class.apply$mcV$sp(Function0.scala:34)
> at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)
> at scala.App$$anonfun$main$1.apply(App.scala:60)
> at scala.App$$anonfun$main$1.apply(App.scala:60)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
> at scala.collection.immutable.List.foreach(List.scala:76)
> at
> scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:30)
> at scala.App$class.main(App.scala:60)
>
>
>

Reply via email to