Yes, the output is unintuitive. The rebalancing ran asynchronously. You can't trigger another one until the previous one completes. Could you file a jira for this?
Thanks, Jun On Mon, Mar 24, 2014 at 1:03 PM, Chris George <ch...@htmlcreators.com>wrote: > When running kafka-preferred kafka-preferred-replica-election.sh for a > second time a node exists exception is being thrown > for /admin/preferred_replica_election > The node doesn't seem to get cleaned up. > > Failed to start preferred replica election > kafka.common.AdminCommandFailedException: Admin command failed > at > > kafka.admin.PreferredReplicaLeaderElectionCommand.moveLeaderToPreferredReplica(PreferredReplicaLeaderElectionCommand.scala:115) > at > > kafka.admin.PreferredReplicaLeaderElectionCommand$.main(PreferredReplicaLeaderElectionCommand.scala:60) > at > > kafka.admin.PreferredReplicaLeaderElectionCommand.main(PreferredReplicaLeaderElectionCommand.scala) > Aborting operation > at > > kafka.admin.PreferredReplicaLeaderElectionCommand$.writePreferredReplicaElectionData(PreferredReplicaLeaderElectionCommand.scala:101) > at > > kafka.admin.PreferredReplicaLeaderElectionCommand.moveLeaderToPreferredReplica(PreferredReplicaLeaderElectionCommand.scala:113) > ... 2 more > Caused by: org.I0Itec.zkclient.exception.ZkNodeExistsException: > org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = > NodeExists for /admin/preferred_replica_election > at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:55) > at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) > at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304) > at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:243) > at kafka.utils.ZkUtils$.createPersistentPath(ZkUtils.scala:337) > at > > kafka.admin.PreferredReplicaLeaderElectionCommand$.writePreferredReplicaElectionData(PreferredReplicaLeaderElectionCommand.scala:95) > ... 3 more > Caused by: org.apache.zookeeper.KeeperException$NodeExistsException: > KeeperErrorCode = NodeExists for /admin/preferred_replica_election > at org.apache.zookeeper.KeeperException.create(KeeperException.java:110) > at org.apache.zookeeper.KeeperException.create(KeeperException.java:42) > at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:643) > at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87) > at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308) > at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304) > at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) > ... 7 more > > -Chris George >
