[
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)
