[轉(zhuǎn)]徹底刪除kafka中的topic

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

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容