[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14165356#comment-14165356 ]
Jun Rao commented on KAFKA-1681: -------------------------------- Sriharsha, I think what Neha meant is that in kafka-1663, the change of the condition in awaitTopicDeletionNotification() is correct. However, kafka-1663 also removed setting deleteTopicStateChanged to true in start() and is causing a new problem. We can just add the following code in start() before the deleteTopicsThread is started. if (topicsToBeDeleted.size > 0) deleteTopicStateChanged.set(true) > Newly elected KafkaController might not start deletion of pending topics > ------------------------------------------------------------------------ > > Key: KAFKA-1681 > URL: https://issues.apache.org/jira/browse/KAFKA-1681 > Project: Kafka > Issue Type: Bug > Reporter: Sriharsha Chintalapani > Priority: Blocker > Fix For: 0.8.2 > > > As part of KAFKA-1663 deleteTopicStateChanged.set(true) is removed from > start(). This will cause newly elected kafka controller not to process the > existing delete topic requests. -- This message was sent by Atlassian JIRA (v6.3.4#6332)