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 標記消失