[jira] [Created] (KAFKA-1202) optimize ZK access in KafkaController

["Jun Rao (JIRA)" <ji...@apache.org>]

Jun Rao created KAFKA-1202:
------------------------------

             Summary: optimize ZK access in KafkaController
                 Key: KAFKA-1202
                 URL: https://issues.apache.org/jira/browse/KAFKA-1202
             Project: Kafka
          Issue Type: Bug
          Components: core
    Affects Versions: 0.8.1
            Reporter: Jun Rao


In KafkaController, we access ZK in the following places. Those accesses are not necessary since we can read from the cache in the controller.

In onBrokerFailure(deadBrokers: Seq[Int]),
replicaStateMachine.handleStateChanges(getAllReplicasOnBroker(zkClient, controllerContext.allTopics.toSeq, deadBrokers), OfflineReplica)
  }

In onBrokerStartup(newBrokers: Seq[Int])
replicaStateMachine.handleStateChanges(getAllReplicasOnBroker(zkClient, controllerContext.allTopics.toSeq, newBrokers), OnlineReplica)
  }

In  shutdownBroker(),
getPartitionsAssignedToBroker(zkClient, controllerContext.allTopics.toSeq, id).map {
  }




--
This message was sent by Atlassian JIRA
(v6.1.5#6160)