Kafka0.8.2.1删除topic逻辑.docx下载

命令： bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name 这条命令其实就是在zookeeper（假设你的chroot就是/）的/admin/delete_topics下创建一个临时节点，名字就是topic名称，比如如果执行命令： bin/kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic test-topic 那么，命令返回后，zookeeper的/admin/delete_topics目录下会新创建一个临时节点test-topic