kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [2/2] git commit: kafka-1681; Newly elected KafkaController might not start deletion of pending topics; patched by Sriharsha Chintalapani; reviewed by Jun Rao
Date Thu, 09 Oct 2014 21:34:54 GMT
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/3d6df549
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3d6df549
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3d6df549

Branch: refs/heads/0.8.2
Commit: 3d6df5494c20dffb7d2765d62bc19d81f16f932c
Parents: 5e45b55
Author: Sriharsha Chintalapani <schintalapani@hortonworks.com>
Authored: Thu Oct 9 14:34:25 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Oct 9 14:34:25 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/3d6df549/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()
     }
   }


Mime
View raw message