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)
