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

Reply via email to