環境描述
kafka集群環境如下,三颱broker,三颱zookeeper,搭建在k8s上
最近搭建為客戶提供kafak生產支援,客戶有乙個測試topic,因為之前使用的是單節點,開發在測試時建立的topic只有乙個replication,乙個partition,對有三個broker的集群來說這樣顯然發揮不了kafka的高併發性和資料安全性,客戶又不想改topic名,所以首先想修改topic
case1:delete.topic.enable=false
檢視所有topic
bin/kafka-topics.sh --list --zookeeper 10.109.47.81:2181,10.96.173.143:2181,10.106.174.196:2181
刪除topic,my_topic
bin/kafka-topics.sh --delete --zookeeper 10.109.47.81:2181,10.96.173.143:2181,10.106.174.196:2181 --topic my_topic
再次檢視topic
這個topic只是被標記下線資料還在沒有完全刪除,根據提示檢視配置檔案delete.topic.enable
修改為如下:
Kafka 如何徹底刪除topic
1 刪除kafka儲存目錄 server.properties檔案log.dirs配置,預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 kafka bin kafka topics.sh delete zookeeper zookeeper位址 to...
Kafka如何徹底刪除topic
kafka如何徹底刪除topic 環境描述 kafka集群環境如下,三颱broker,三颱zookeeper,搭建在k8s上 最近搭建為客戶提供kafak生產支援,客戶有乙個測試topic,因為之前使用的是單節點,開發在測試時建立的topic只有乙個replication,乙個partition,對...
Kafka徹底刪除topic
kafka預設僅做刪除標記,並沒有真實刪除,若要真實刪除topic server.properties新增 delete.topic.enable true,然後重啟 刪除測試 建立topic bin kafka topics.sh create zookeeper 127.0.0.1 2180 r...