Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1558

AdminUtils.deleteTopic does not work

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 0.8.1.1
    • 0.8.2.0
    • None
    • None

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

      Attachments

        1. KAFKA-1558.patch
          3 kB
          Harsha
        2. kafka-thread-dump.log
          41 kB
          Harsha

        Issue Links

          Activity

            People

              sriharsha Harsha
              henning Henning Schmiedehausen
              Neha Narkhede Neha Narkhede
              Votes:
              0 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: