[
https://issues.apache.org/jira/browse/KAFKA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1202:
---------------------------
Attachment: KAFKA-1202.patch
> 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
> Attachments: KAFKA-1202.patch
>
>
> 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)
