[
https://issues.apache.org/jira/browse/KAFKA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1202.
----------------------------
Resolution: Fixed
Fix Version/s: 0.8.1
Thanks for the review. Committed to trunk. Also, incorporated changes in
kafka-1020.
> 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
> Assignee: Jun Rao
> Fix For: 0.8.1
>
> 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)
