You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Mohit Anchlia <mo...@gmail.com> on 2014/10/24 20:22:56 UTC
kafka.common.ConsumerRebalanceFailedException
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)
Re: kafka.common.ConsumerRebalanceFailedException
Posted by Neha Narkhede <ne...@gmail.com>.
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 <mo...@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)
>