[KAFKA-1558] AdminUtils.deleteTopic does not work

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.8.1.1
• Fix Version/s: 0.8.2.0
• Assignee: Harsha
• Reporter: Henning Schmiedehausen
• Reviewer: Neha Narkhede
• Created: 26/Jul/14 23:49
• Updated: 30/Aug/23 16:28
• Resolved: 09/Oct/14 21:54

Description

the AdminUtils:.deleteTopic method is implemented as

    def deleteTopic(zkClient: ZkClient, topic: String) {
        ZkUtils.createPersistentPath(zkClient, ZkUtils.getDeleteTopicPath(topic))
    }

but the DeleteTopicCommand actually does

    zkClient = new ZkClient(zkConnect, 30000, 30000, ZKStringSerializer)
    zkClient.deleteRecursive(ZkUtils.getTopicPath(topic))

so I guess, that the 'createPersistentPath' above should actually be

    def deleteTopic(zkClient: ZkClient, topic: String) {
        ZkUtils.deletePathRecursive(zkClient, ZkUtils.getTopicPath(topic))
    }

Issue Links

• is depended upon by: KAFKA-1663 Controller unable to shutdown after a soft failure