刚接触Kafka,开始认为删除一个topic只是运行一下Kafka-topic.sh的delete命令就好了,可是,事实却不是这样,会出现两种状况:(1) 若是topic没有使用过即没有传输过消息,能够完全删除;(2)若是当前topic有使用过,则只会把topic标记为删除工具
此时若是须要完全删除topic须要删除Zookeeper上的相关路径,Kafka自带了简单的Zookeeper客户端工具spa
删除节点code
此时在看topic列表,发现topic以及被删除了blog
最后再把topic的临时文件夹删除就好了kafka
rm -r /tmp/kafka-logs/test-cluster-*
完成。class