kafka刪除topic及其相關數據


1、刪除kafka存儲目錄(server.properties文件log.dirs配置,默認為"/tmp/kafka-logs")相關topic目錄

2、Kafka 刪除topic的命令是:

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

     如果kafaka啟動時加載的配置文件中server.properties沒有配置delete.topic.enable=true,那么此時的刪除並不是真正的刪除,而是把topic標記為:marked for deletion

     你可以通過命令:./bin/kafka-topics --zookeeper 【zookeeper server】 --list 來查看所有topic

 

     此時你若想真正刪除它,可以如下操作:

     (1)登錄zookeeper客戶端:命令:./bin/zookeeper-client

     (2)找到topic所在的目錄:ls /brokers/topics

     (3)找到要刪除的topic,執行命令:rmr /brokers/topics/【topic name】即可,此時topic被徹底刪除。

 

    另外被標記為marked for deletion的topic你可以在zookeeper客戶端中通過命令獲得:ls /admin/delete_topics/【topic name】,

    如果你刪除了此處的topic,那么marked for deletion 標記消失

    zookeeper 的config中也有有關topic的信息: ls /config/topics/【topic name】暫時不知道有什么用

 

總結:

徹底刪除topic:

 1、刪除kafka存儲目錄(server.properties文件log.dirs配置,默認為"/tmp/kafka-logs")相關topic目錄

 2、如果配置了delete.topic.enable=true直接通過命令刪除,如果命令刪除不掉,直接通過zookeeper-client 刪除掉broker下的topic即可。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM