文件名称:Kafka0.8.2.1删除topic逻辑.docx
文件大小:35KB
文件格式:DOCX
更新时间:2021-10-29 05:04:07
kafka
命令: 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