【Kafka】Kafka topic主題删除不了

前言

利用kafka指令删除topic不成功。

kafka-topics.sh --zookeeper hadoop111:2181 --delete --topic test
           

原因&解決方式

1. 配置檔案未将delete.topic.enable=true，導緻删除指令未及時生效；

解決方式：

第一種：

找到conf目錄下server.properties配置檔案，修改delete.topic.enable=true，代表删除立即生效；

[ssrs@hadoop111 config]$ pwd
/opt/module/kafka_2.11/config
[ssrs@hadoop111 config]$ vi server.properties
           

delete.topic.enable=true
           

修改配置後，需要重新開機kafka服務；

第二種：

不修改delete.topic.enable=true配置檔案的情況下，删除指令執行後，重新開機kafka服務，也可以使主題删除成功；

2. 配置檔案已經設定delete.topic.enable=true，删除指令執行後，還能看到topic名稱；

原因：

生産者和消費者并未停止執行，導緻雖然删除了topic，但是生産者或者消費者運作時，立刻重新建立了topic，視覺顯示删除未成功，此時可以通過消費topic内的資料進行檢視，如果之前是帶有資料的topic，在執行删除指令後，發現topic内的資料已經消失了。

先停止生産者和消費者的運作，再執行kafka删除指令；

作者：ShadowFiend

出處：http://www.cnblogs.com/ShadowFiend/

本文版權歸作者和部落格園共有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接配接，否則保留追究法律責任的權利。如有問題或建議，請多多賜教，非常感謝。