Hi Jianbin; I tried like this; Where I provided my zookeeper host. But it says[1] . I use kafka 0.10. And I see my topic available using KafkaManagementTool.
How can I overcome this issue? [1]Error while executing topic command : Topic targettopic does not exist on ZK path zookeeper.xx.com:2181/chroot *[2016-10-14 11:58:59,919] ERROR java.lang.IllegalArgumentException: Topic streamtargettopic does not exist on ZK path zookeeper.xx.com:2181/chroot <http://zookeeper.xx.com:2181/chroot>* * at kafka.admin.TopicCommand$.deleteTopic(TopicCommand.scala:169)* * at kafka.admin.TopicCommand$.main(TopicCommand.scala:69)* * at kafka.admin.TopicCommand.main(TopicCommand.scala)* bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name On 12 October 2016 at 17:02, Ratha v <vijayara...@gmail.com> wrote: > Thank you.. > > On 12 October 2016 at 16:30, Jianbin Wei <jianbin....@netskope.com> wrote: > >> You can check this >> >> http://kafka.apache.org/documentation.html#basic_ops_add_topic >> >> But from our experience it is best to delete topics one by one, i.e., >> make sure Kafka is in good shape before and after deleting a topic before >> working on next one. >> >> Regards, >> >> -- Jianbin >> >> > On Oct 11, 2016, at 9:26 PM, Ratha v <vijayara...@gmail.com> wrote: >> > >> > Thanks..Which bash script I need to run? >> > >> >> On 12 October 2016 at 15:20, Ali Akhtar <ali.rac...@gmail.com> wrote: >> >> >> >> The last time I tried, I couldn't find a way to do it, other than to >> >> trigger the bash script for topic deletion programatically. >> >> >> >>> On Wed, Oct 12, 2016 at 9:18 AM, Ratha v <vijayara...@gmail.com> >> wrote: >> >>> >> >>> Hi all; >> >>> >> >>> I have two topics(source and target). I do some processing on the >> message >> >>> available in the source topic and i merge both topic. >> >>> That is; >> >>> >> >>> builder.stream(sourceTopic).to(targetTopic) >> >>> >> >>> Once merged I no longer require the sourceTopic. I want to delete it. >> >>> >> >>> How can I do that programatically in java? I use highelevel client >> APIs, >> >>> kafka v 0.10.0.1 >> >>> >> >>> >> >>> Thanks >> >>> -- >> >>> -Ratha >> >>> http://vvratha.blogspot.com/ >> >>> >> >> >> > >> > >> > >> > -- >> > -Ratha >> > http://vvratha.blogspot.com/ >> > > > > -- > -Ratha > http://vvratha.blogspot.com/ > -- -Ratha http://vvratha.blogspot.com/
