Hi , If my topic is not enabled for deletion any other way to purge message from topic ?
*Regards,* *Laxmi Narayan Patel* *MCA NIT Durgapur (2011-2014)* *Mob:- 9741292048,8345847473 * On Fri, Jan 13, 2017 at 12:16 AM, Kaufman Ng <kauf...@confluent.io> wrote: > Your zookeeper url doesn't look right. Port 9092 is kafka broker's default > listening port. Zookeeper's default is 2181. > > > On Thu, Jan 12, 2017 at 1:33 PM, Laxmi Narayan NIT DGP < > nit.dgp...@gmail.com > > wrote: > > > /bin/kafka-topics.sh --zookeeper localhost:9092 --delete --topic > topicName > > > > > > I am getting exception saying : > > > > [2017-01-13 00:01:45,101] WARN Client session timed out, have not heard > > from server in 15016ms for sessionid 0x0 (org.apache.zookeeper. > ClientCnxn) > > [2017-01-13 00:02:00,902] WARN Client session timed out, have not heard > > from server in 15001ms for sessionid 0x0 (org.apache.zookeeper. > ClientCnxn) > > Exception in thread "main" > > org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to > > zookeeper server within timeout: 30000 > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1232) > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:156) > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:130) > > at kafka.utils.ZkUtils$.createZkClientAndConnection( > ZkUtils.scala:76) > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:58) > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:53) > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > > > > > > > > > > > ** > > > > *Regards,* > > *Laxmi Narayan Patel* > > *MCA NIT Durgapur (2011-2014)* > > *Mob:- 9741292048,8345847473 * > > > > > > -- > Kaufman Ng > +1 646 961 8063 > Solutions Architect | Confluent | www.confluent.io >
