Does that error occur continuously? Preferred leaders are the first replica in the assigned replica list. Could you list the topics and see the distribution of the first replica in all partitions?
Thanks, Jun 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 >
