[ https://issues.apache.org/jira/browse/KAFKA-14234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yan Xue updated KAFKA-14234: ---------------------------- Description: I deployed the Kafka cluster on Kuberentes and am trying to figure out how topic deletion works. I know Kafka controller has the topic deletion manager which watches the node change in the zookeeper. Whenever a topic is deleted, the manager is triggered. I expected to see that the {{/admin/delete_topics}} is in the watcher list. However, I didn't find it. Sample output: root@kafka-broker-2:/opt/kafka# echo wchc | nc ZOOKEEPER_IP 2181 0x200100211390000 /admin/preferred_replica_election /brokers/ids/0 /brokers/ids/1 /brokers/ids/2 /brokers/topics/__consumer_offsets /brokers/ids/3 /brokers/ids/4 /controller /admin/reassign_partitions /brokers/topics/test-test /feature 0x200100211390001 /controller /feature 0x1631f90000 /controller /feature Even though I can delete the topic, I am confused about the output. was: I deployed the Kafka cluster on Kuberentes and am trying to figure out how topic deletion works. I know Kafka controller has the topic deletion manager which watches the node change in the zookeeper. Whenever a topic is deleted, the manager is triggered. I expected to see that the {{/admin/delete_topics}} is in the watcher list. However, I didn't find it. Sample output: root@kafka-broker-2:/opt/kafka# echo wchc | nc ZOOKEEPER_IP 2181 0x200100211390000 /admin/preferred_replica_election /brokers/ids/0 /brokers/ids/1 /brokers/ids/2 /brokers/topics/__consumer_offsets /brokers/ids/3 /brokers/ids/4 /controller /admin/reassign_partitions /brokers/topics/test-test /feature 0x200100211390001 /controller /feature 0x1631f90000 /controller /feature > /admin/delete_topics is not in the list of zookeeper watchers > ------------------------------------------------------------- > > Key: KAFKA-14234 > URL: https://issues.apache.org/jira/browse/KAFKA-14234 > Project: Kafka > Issue Type: Bug > Components: controller > Affects Versions: 3.2.1 > Reporter: Yan Xue > Priority: Minor > > I deployed the Kafka cluster on Kuberentes and am trying to figure out how > topic deletion works. I know Kafka controller has the topic deletion manager > which watches the node change in the zookeeper. Whenever a topic is deleted, > the manager is triggered. I expected to see that the {{/admin/delete_topics}} > is in the watcher list. However, I didn't find it. Sample output: > root@kafka-broker-2:/opt/kafka# echo wchc | nc ZOOKEEPER_IP 2181 > 0x200100211390000 > /admin/preferred_replica_election > /brokers/ids/0 > /brokers/ids/1 > /brokers/ids/2 > /brokers/topics/__consumer_offsets > /brokers/ids/3 > /brokers/ids/4 > /controller > /admin/reassign_partitions > /brokers/topics/test-test > /feature > 0x200100211390001 > /controller > /feature > 0x1631f90000 > /controller > /feature > > Even though I can delete the topic, I am confused about the output. -- This message was sent by Atlassian Jira (v8.20.10#820010)