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目录下会新创建一