[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14163604#comment-14163604 ]
Sriharsha Chintalapani commented on KAFKA-1681: ----------------------------------------------- [~nehanarkhede] [~junrao] adding this code to TopicDeletionManager.start method should cover this issue right? if (topicsToBeDeleted.size > 0) resumeTopicDeletionThread() > 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)