Hi, As per the jira https://issues.apache.org/jira/browse/KAFKA-1737, I have set ZKStringSerializer, while creating the ZkClient and still the delete topic function call is not working:
Version: kafka_2.11-0.8.2.1 *My code looks like this*: ZkClient zkClient = new ZkClient("localhost:2181", 6000, 6000, ZKStringSerializer$.MODULE$); AdminUtils.deleteTopic(zkClient, "testTopic17"); *I am getting the following exception's*: Exception in thread "main" org.I0Itec.zkclient.exception.ZkNodeExistsException: org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists for /admin/delete_topics/testTopic17 at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:55) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304) at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:243) at kafka.utils.ZkUtils$.createPersistentPath(ZkUtils.scala:306) at kafka.admin.AdminUtils$.deleteTopic(AdminUtils.scala:159) at kafka.admin.AdminUtils.deleteTopic(AdminUtils.scala) at Test.deleteTopic(Test.java:98) at Test.main(Test.java:76) Caused by: org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists for /admin/delete_topics/testTopic17 at org.apache.zookeeper.KeeperException.create(KeeperException.java:119) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783) at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87) at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308) at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 7 more *The corresponding zookeeper logs*: [2015-07-16 15:31:14,383] INFO Accepted socket connection from / 127.0.0.1:23363 (org.apache.zookeeper.server.NIOServerCnxnFactory) [2015-07-16 15:31:14,385] INFO Client attempting to establish new session at /127.0.0.1:23363 (org.apache.zookeeper.server.ZooKeeperServer) [2015-07-16 15:31:14,391] INFO Established session 0x14e98d2ce98000c with negotiated timeout 6000 for client /127.0.0.1:23363 (org.apache.zookeeper.server.ZooKeeperServer) [2015-07-16 15:31:14,510] INFO Got user-level KeeperException when processing sessionid:0x14e98d2ce98000c type:create cxid:0x1 zxid:0x963 txntype:-1 reqpath:n/a Error Path:/admin/delete_topics/testTopic17 Error:KeeperErrorCode = NodeExists for /admin/delete_topics/testTopic17 (org.apache.zookeeper.server.PrepRequestProcessor) [2015-07-16 15:31:14,842] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn) EndOfStreamException: Unable to read additional data from client sessionid 0x14e98d2ce98000c, likely client has closed socket at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) at java.lang.Thread.run(Thread.java:744) [2015-07-16 15:31:14,843] INFO Closed socket connection for client / 127.0.0.1:23363 which had sessionid 0x14e98d2ce98000c (org.apache.zookeeper.server.NIOServerCnxn) [2015-07-16 15:31:21,000] INFO Expiring session 0x14e98d2ce98000c, timeout of 6000ms exceeded (org.apache.zookeeper.server.ZooKeeperServer) [2015-07-16 15:31:21,001] INFO Processed session termination for sessionid: 0x14e98d2ce98000c (org.apache.zookeeper.server.PrepRequestProcessor) Could someone please let me know if I am missing anything? Thank you, Siva.