Thanks Harsha, exactly what I was looking for. Sumit
On Fri, Jan 23, 2015 at 12:24 PM, Harsha <ka...@harsha.io> wrote: > Sumit, > You can use AdminUtils.deleteTopic(zkClient, topicName) . This > will initiate the deleteTopic process by zookeeper notification > to KafkaController.deleteTopicManager. It deletes log files > along with zookeeper topic path as Timothy mentioned. > -Harsha > > On Fri, Jan 23, 2015, at 12:18 PM, Timothy Chen wrote: > > I believe that's the only way it's supported from the CLI. > > > > Delete topic actually fully removes the topic from the cluster, which > > also includes cleaning the logs and removing it from zookeeper (once > > it is fully deleted). > > > > Tim > > > > On Fri, Jan 23, 2015 at 12:13 PM, Sumit Rangwala > > <sumitrangw...@gmail.com> wrote: > > > I am trying to find if there is a supported API to delete topic (from > > > within my code) specifically in 0.8.2. One method that I can think of > is > > > calling kafka.admin.TopicCommand.main with the same parameters as one > gives > > > on the command line. Is this the recommended way or is there a better > way > > > of doing it? > > > > > > Furthermore, are the details of deleting a topic in 0.8.2 documented, > since > > > I would like to understand if delete topic only deletes the topic in > > > zookeeper or it also cleans the logs in kafka broker as well. > > > > > > > > > Sumit >