1、停止要刪除topic的生產和消費程式,否則無法刪除。同時,需要設定auto.create.topics.enable = false,預設設定為true,如果設定為true,則produce或者fetch 不存在的topic也會自動建立這個topic。這樣會給刪除topic帶來很多意向不到的問題。
2、server.properties 設定delete.topic.enable=true,如果沒有設定 delete.topic.enable=true,則呼叫kafka 的delete命令無法真正將topic刪除,而是顯示(marked for deletion)
1、先查詢儲存目錄:vi config/server.properties
,找到log.dirs字段
2、查詢到的目錄:log.dirs=/root/code/packages/data/kk/logs
3、進入儲存目錄:cd /root/code/packages/data/kk/logs
,刪除相關的topic的資料目錄
ps:如果還是無法刪除topic,則需要對kafka中的zookeeper儲存資訊刪除。
2、登入zk shell之後,找到topic目錄:ls /brokers/topics
3、找到要刪除的topic:rmr /brokers/topics/[要刪除的topic名稱]
4、如果topic被標記為marked for deletion,則通過ls /admin/delete_topics
,找到要刪除的topic,然後在執行命令:rmr /admin/delete_topics/[要刪除的topic名稱]
檢視刪除的topic是否還在,如果這裡還是出現,則重啟zookeeper和kafka就可以了。
kafka 徹底刪除 topic 及資料
預設情況,當我們刪除 topic 並不會真正刪除,只是把佇列標記為 marked for deletion 如果我們要徹底刪除 topic 及資料,可採用一下方法 方法一 修改 kafka conf server.properties,增加 delete.topic.enable true,然後重啟...
Kafka徹底刪除topic
kafka預設僅做刪除標記,並沒有真實刪除,若要真實刪除topic server.properties新增 delete.topic.enable true,然後重啟 刪除測試 建立topic bin kafka topics.sh create zookeeper 127.0.0.1 2180 r...
kafka徹底刪除topic
刪除topic一般是下面這樣的,但是這樣是刪不掉的,只是標記為刪除,再次建立同名topic還是會報錯,topic已經存在.kafka topics.sh zookeeper mypc01 2181 mypc02 2181 mypc03 2181 kafka delete topic pet首先 se...