删除Kafka的topic

        刚接触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

相关文章
相关标签/搜索