From e8c72901bd324ab9bc7b92101c4fc1bd2528cd3a Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Thu, 9 Oct 2014 12:52:23 -0700 Subject: [PATCH] KAFKA-1681. Newly elected KafkaController might not start deletion of pending topics. --- core/src/main/scala/kafka/controller/TopicDeletionManager.scala | 2 ++ 1 file changed, 2 insertions(+) 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() } } -- 1.8.5.2 (Apple Git-48)