Check delete state of topic
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/00afb619 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/00afb619 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/00afb619 Branch: refs/heads/trunk Commit: 00afb619cb1f2aaca0ddc785ab1d649428f9c93e Parents: 5b80758 Author: Sriram Subramanian <[email protected]> Authored: Tue Feb 25 00:26:14 2014 -0800 Committer: Sriram Subramanian <[email protected]> Committed: Tue Feb 25 00:26:14 2014 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/controller/KafkaController.scala | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/00afb619/core/src/main/scala/kafka/controller/KafkaController.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala index f12ffc2..b58cdcd 100644 --- a/core/src/main/scala/kafka/controller/KafkaController.scala +++ b/core/src/main/scala/kafka/controller/KafkaController.scala @@ -1114,7 +1114,6 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends Logg controllerContext.partitionsBeingReassigned.size == 0 && controllerContext.partitionsUndergoingPreferredReplicaElection.size == 0 && !deleteTopicManager.isTopicQueuedUpForDeletion(topicPartition.topic) && - !deleteTopicManager.isTopicDeletionInProgress(topicPartition.topic) && controllerContext.allTopics.contains(topicPartition.topic)) { onPreferredReplicaElection(Set(topicPartition), false) }
