Can you see if the workarounds mentioned here <https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Myconsumerseemstohavestopped,why?> for failed rebalance attempts is useful?
On Fri, Oct 24, 2014 at 11:22 AM, Mohit Anchlia <mohitanch...@gmail.com> wrote: > I am seeing following exception, don't understand the issue here. Is there > a way to resolve this error? > > client consumer logs: > > > Exception in thread "main" kafka.common.ConsumerRebalanceFailedException: > groupB_ip-10-38-19-230-1414174925481-97fa3f2a can't rebalance after 4 > retries > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:432) > at > > kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:722) > at > > kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:212) > at kafka.javaapi.consumer.Zookeep > > > server logs: > > > > [2014-10-24 14:21:47,327] INFO Got user-level KeeperException when > processing sessionid:0x149435a553d007d type:create cxid:0x97 zxid:0xb4e > txntype:-1 reqpath:n/a Error Path:/consumers/groupB/owners/topicA/28 > Error:KeeperErrorCode = NodeExists for /consumers/groupB/owners/topicA/28 > (org.apache.zookeeper.server.PrepRequestProcessor) > [2014-10-24 14:21:47,329] INFO Got user-level KeeperException when > processing sessionid:0x149435a553d007d type:create cxid:0x99 zxid:0xb4f > txntype:-1 reqpath:n/a Error Path:/consumers/groupB/owners/topicA/23 > Error:KeeperErrorCode = NodeExists for /consumers/groupB/owners/topicA/23 > (org.apache.zookeeper.server.PrepRequestProcessor) >
