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.
