【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刪除命令;


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM