[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14159379#comment-14159379 ]
Neha Narkhede commented on KAFKA-1558: -------------------------------------- [~sriharsha] Now that KAFKA-1663 is pushed to trunk, the previously failing test should now pass right? The only other thing to wait on would be the leader rebalance tests. [~clarkhaskins], [~guozhang]: At this point, many failure tests pass on delete topic. It will be great to try delete topic on 100s of topics on some of LinkedIn's clusters, if possible. Any chance this test can happen in the 0.8.2 timeframe (1-2 weeks) ? > AdminUtils.deleteTopic does not work > ------------------------------------ > > Key: KAFKA-1558 > URL: https://issues.apache.org/jira/browse/KAFKA-1558 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.8.1.1 > Reporter: Henning Schmiedehausen > Assignee: Sriharsha Chintalapani > Priority: Blocker > Fix For: 0.8.2 > > Attachments: kafka-thread-dump.log > > > the AdminUtils:.deleteTopic method is implemented as > {code} > def deleteTopic(zkClient: ZkClient, topic: String) { > ZkUtils.createPersistentPath(zkClient, > ZkUtils.getDeleteTopicPath(topic)) > } > {code} > but the DeleteTopicCommand actually does > {code} > zkClient = new ZkClient(zkConnect, 30000, 30000, ZKStringSerializer) > zkClient.deleteRecursive(ZkUtils.getTopicPath(topic)) > {code} > so I guess, that the 'createPersistentPath' above should actually be > {code} > def deleteTopic(zkClient: ZkClient, topic: String) { > ZkUtils.deletePathRecursive(zkClient, ZkUtils.getTopicPath(topic)) > } > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)