Hello Jon, Did you see all 3 brokers registered in ZK? From the error logs it seems some of the brokers did not successfully startup and hence cannot take any partitions.
Guozhang On Wed, May 14, 2014 at 11:45 AM, Jon Bender <jonathan.ben...@gmail.com>wrote: > Hello, > > I have a 3-node cluster that has had a couple issues lately. One thing I'm > trying to sort out is why the topic-partitions are all owned by a single > leader (when i list topics, the leader is assigned to the current > controller node, irrespective the preferred replica). > > I have tried to use the preferred replica election tool per: > > https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-2.PreferredReplicaLeaderElectionTool > > But I don't see any change taking place. > > Only thing I see in the logs on this machine is: > > [2014-05-14 11:37:22,146] 69818066 > [ZkClient-EventThread-21-my.server1:2181,my.server2:2181,my.server3:2181] > INFO kafka.utils.ZkUtils$ - conflict in /controller data: { > "brokerid":1390348134, "timestamp":"1400026164986", "version":1 } stored > data: { "brokerid":1390348134, "timestamp":"1400026164512", "version":1 } > [2014-05-14 11:37:22,147] 69818067 > [ZkClient-EventThread-21-my.server1:2181,my.server2:2181,my.server3:2181] > INFO kafka.utils.ZkUtils$ - I wrote this conflicted ephemeral node [{ > "brokerid":1390348134, "timestamp":"1400026164986", "version":1 }] at > /controller a while back in a different session, hence I will backoff for > this node to be deleted by Zookeeper and retry > > Kafka version is 0.8.0. > > Any suggestions on how to get this cluster to properly rebalance? > > Cheers, > Jon > -- -- Guozhang
