Thanks Harsha, exactly what I was looking for.
Sumit
On Fri, Jan 23, 2015 at 12:24 PM, Harsha wrote:
> Sumit,
>You can use AdminUtils.deleteTopic(zkClient, topicName) . This
>will initiate the deleteTopic process by zookeeper notification
>to KafkaController.deleteTopic
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 2
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
wrote:
> I am trying t
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 doi
