[jira] [Updated] (KAFKA-1558) AdminUtils.deleteTopic does not work

[Henning Schmiedehausen (JIRA)]

     [ 
https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Henning Schmiedehausen updated KAFKA-1558:
------------------------------------------

    Description: 
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}


  was:
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))
      }




> 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
>
> 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.2#6252)