1. 程式人生 > >徹底刪除Kafka中的topic

徹底刪除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即可。