© 1999-2048 dssz.net 粤ICP备11031372号
[kafka] 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-to<u011612291> 上传 | 大小:35kb