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