Browse Source

Check delete state of topic

pull/223/head
Sriram Subramanian 11 years ago
parent
commit
00afb619cb
  1. 1
      core/src/main/scala/kafka/controller/KafkaController.scala

1
core/src/main/scala/kafka/controller/KafkaController.scala

@ -1114,7 +1114,6 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends Logg @@ -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)
}

Loading…
Cancel
Save