kafka如何徹底刪除topic及資料

2021-09-23 13:20:59 字數 2170 閱讀 3609

刪除kafka topic及其資料,嚴格來說並不是很難的操作。但是,往往給kafka 使用者帶來諸多問題。專案組之前接觸過多個開發者,發現都會偶然出現無法徹底刪除kafka的情況。本文總結多個刪除kafka topic的應用場景,總結一套刪除kafka topic的標準操作方法。

step1:

如果需要被刪除topic 此時正在被程式 produce和consume,則這些生產和消費程式需要停止。

因為如果有程式正在生產或者消費該topic,則該topic的offset資訊一致會在broker更新。呼叫kafka delete命令則無法刪除該topic。

同時,需要設定 auto.create.topics.enable = false,預設設定為true。如果設定為true,則produce或者fetch 不存在的topic也會自動建立這個topic。這樣會給刪除topic帶來很多意向不到的問題。

所以,這一步很重要,必須設定auto.create.topics.enable = false,並認真把生產和消費程式徹底全部停止。

step2:

server.properties設定 delete.topic.enable=true

如果沒有設定 delete.topic.enable=true,則呼叫kafka 的delete命令無法真正將topic刪除,而是顯示(marked for deletion)

step3:

呼叫命令刪除topic:

./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】

step4:

刪除kafka儲存目錄(server.properties檔案log.dirs配置,預設為"/data/kafka-logs")相關topic的資料目錄。

注意:如果kafka 有多個 broker,且每個broker 配置了多個資料盤(比如 /data/kafka-logs,/data1/kafka-logs ...),且topic也有多個分割槽和replica,則需要對所有broker的所有資料盤進行掃瞄,刪除該topic的所有分割槽資料。

一般而言,經過上面4步就可以正常刪除掉topic和topic的資料。但是,如果經過上面四步,還是無法正常刪除topic,則需要對kafka在zookeeer的儲存資訊進行刪除。具體操作如下:

(注意:以下步驟裡面,kafka在zk裡面的節點資訊是採用預設值,如果你的系統修改過kafka在zk裡面的節點資訊,則需要根據系統的實際情況找到準確位置進行操作)

step5:

找一台部署了zk的伺服器,使用命令:

bin/zkcli.sh -server 【zookeeper server:port】

登入到zk shell,然後找到topic所在的目錄:ls /brokers/topics,找到要刪除的topic,然後執行命令:

rmr /brokers/topics/【topic name】

即可,此時topic被徹底刪除。

如果topic 是被標記為 marked for deletion,則通過命令 ls /admin/delete_topics,找到要刪除的topic,然後執行命令:

rmr /admin/delete_topics/【topic name】

備註:

rmr /consumers/【consumer-group】

rmr /config/topics/【topic name】

其實正常情況是不需要進行這兩個操作的,如果需要,那都是由於操作不當導致的。比如step1停止生產和消費程式沒有做,step2沒有正確配置。也就是說,正常情況下嚴格按照step1 -- step5 的步驟,是一定能夠正常刪除topic的。

step6:

完成之後,呼叫命令:

./bin/kafka-topics.sh --list --zookeeper 【zookeeper server:port】

檢視現在kafka的topic資訊。正常情況下刪除的topic就不會再顯示。

但是,如果還能夠查詢到刪除的topic,則重啟zk和kafka即可。

Kafka 如何徹底刪除topic

1 刪除kafka儲存目錄 server.properties檔案log.dirs配置,預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 kafka bin kafka topics.sh delete zookeeper zookeeper位址 to...

Kafka如何徹底刪除topic

環境描述 kafka集群環境如下,三颱broker,三颱zookeeper,搭建在k8s上 最近搭建為客戶提供kafak生產支援,客戶有乙個測試topic,因為之前使用的是單節點,開發在測試時建立的topic只有乙個replication,乙個partition,對有三個broker的集群來說這樣顯...

Kafka如何徹底刪除topic

kafka如何徹底刪除topic 環境描述 kafka集群環境如下,三颱broker,三颱zookeeper,搭建在k8s上 最近搭建為客戶提供kafak生產支援,客戶有乙個測試topic,因為之前使用的是單節點,開發在測試時建立的topic只有乙個replication,乙個partition,對...