剛接觸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