[
https://issues.apache.org/jira/browse/KAFKA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13869309#comment-13869309
]
Jun Rao commented on KAFKA-1202:
--------------------------------
Created reviewboard https://reviews.apache.org/r/16814/
against branch origin/trunk
> 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)
