#Kafka 徹底刪除topic


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

2、可以通過bin下面的 bin/kafka-topics.sh 

--delete                                 Delete a topic   
--zookeeper
--topic <topic>
# ./bin/kafka-topics  --delete --zookeeper 192.168.100.1:2181  --topic  mysql_topic   

#如果kafaka啟動時加載的配置文件中server.properties沒有配置delete.topic.enable=true,

那么此時的刪除並不是真正的刪除,而是把topic標記為:marked for deletion

你可以通過命令:./bin/kafka-topics.sh --zookeeper 192.168.100.1:2181 --list 來查看所有topic

 

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

(1)啟動zookeeper客戶端:

root@localhost:/data/zookeeper-3.4.10# bin/zkCli.sh

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

[zk: localhost:2181(CONNECTED) 0] ls /brokers/topics

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

 

另外被標記為marked for deletion的topic你可以在zookeeper客戶端中通過命令獲得

[zk: localhost:2181(CONNECTED) 0] ls /admin/delete_topics

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


免責聲明!

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



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