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 <schintalapani@hortonworks.com>
Authored: Thu Oct 9 14:29:21 2014 -0700
Committer: Jun Rao <junrao@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()
}
}
|