From 00afb619cb1f2aaca0ddc785ab1d649428f9c93e Mon Sep 17 00:00:00 2001
From: Sriram Subramanian <sriram.sub@gmail.com>
Date: Tue, 25 Feb 2014 00:26:14 -0800
Subject: [PATCH] Check delete state of topic

---
 core/src/main/scala/kafka/controller/KafkaController.scala | 1 -
 1 file changed, 1 deletion(-)

diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala
index f12ffc2af1f..b58cdcd16ff 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)
                   }