前言
利用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刪除命令;