Hello Sivananda,
Calling AdminUtils.deleteTopic just requests topic to be deleted - it does
not actually delete topic immediately. Requests for topic deletion get
saved in ZooKeeper as a node (named by topic name), under
/admin/delete_topics node.
If brokers in the cluster are configured with top
Looks like you try to delete a topic that is already in the process of
getting deleted:
NodeExists for /admin/delete_topics/testTopic17
(We can improve the error messages for sure, or maybe even catch the
exception and ignore it)
Gwen
On Thu, Jul 16, 2015 at 3:40 PM, Sivananda Reddy
wrote:
> Hi
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
