1、刪除kafka存儲目錄(server.properties文件log.dirs配置,默認(rèn)為"/tmp/kafka-logs")相關(guān)topic目錄
2、Kafka 刪除topic的命令是:
./bin/kafka-topics --delete --zookeeper 【zookeeper server】 --topic 【topic name】
如果kafaka啟動(dòng)時(shí)加載的配置文件中server.properties沒有配置delete.topic.enable=true,那么此時(shí)的刪除并不是真正的刪除,而是把topic標(biāo)記為:marked for deletion
你可以通過命令:
./bin/kafka-topics --zookeeper 【zookeeper server】 --list
來查看所有topic
此時(shí)你若想真正刪除它,可以登錄zookeeper客戶端:
命令:
./bin/zookeeper-client
找到topic所在的目錄:
ls /brokers/topics
找到要?jiǎng)h除的topic,執(zhí)行命令:
rmr /brokers/topics/【topic name】
即可,此時(shí)topic被徹底刪除
另外被標(biāo)記為marked for deletion的topic你可以在zookeeper客戶端中通過命令獲得:
ls /admin/delete_topics/【topic name】
如果你刪除了此處的topic,那么marked for deletion 標(biāo)記消失
zookeeper 的config中也有有關(guān)topic的信息:
ls /config/topics/【topic name】
暫時(shí)不知道有什么用
總結(jié):
徹底刪除topic:
1、刪除kafka存儲目錄(server.properties文件log.dirs配置,默認(rèn)為"/tmp/kafka-logs")相關(guān)topic目錄
2、如果配置了delete.topic.enable=true直接通過命令刪除,如果命令刪除不掉,直接通過zookeeper-client 刪除掉broker下的topic即可。
文章來源: http://blog.csdn.net/fengzheku/article/details/50585972