You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/10/09 23:29:32 UTC
git commit: kafka-1681;
Newly elected KafkaController might not start deletion of pending
topics; patched by Sriharsha Chintalapani; reviewed by Jun Rao
Repository: kafka
Updated Branches:
refs/heads/trunk c940470e3 -> a7e49298b
kafka-1681; Newly elected KafkaController might not start deletion of pending topics; patched by Sriharsha Chintalapani; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a7e49298
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a7e49298
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a7e49298
Branch: refs/heads/trunk
Commit: a7e49298b02ae35c227a40deae63debeae91138f
Parents: c940470
Author: Sriharsha Chintalapani <sc...@hortonworks.com>
Authored: Thu Oct 9 14:29:21 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Thu Oct 9 14:29:21 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/controller/TopicDeletionManager.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/a7e49298/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/TopicDeletionManager.scala b/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
index 6ee3de2..e56f22d 100644
--- a/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
+++ b/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
@@ -89,6 +89,8 @@ class TopicDeletionManager(controller: KafkaController,
def start() {
if (isDeleteTopicEnabled) {
deleteTopicsThread = new DeleteTopicsThread()
+ if (topicsToBeDeleted.size > 0)
+ deleteTopicStateChanged.set(true)
deleteTopicsThread.start()
}
}