kafka刪除新建topic

2021-07-29 03:12:34 字數 1227 閱讀 9135

原理翻譯可參考:

刪除kafka的topic,參照

1、刪除kafka儲存目錄(server.properties檔案log.dirs配置,預設為"/tmp/kafka-logs")相關topic目錄

2、kafka 刪除topic的命令是:

./bin/kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】

如果kafaka啟動時載入的配置檔案中server.properties沒有配置delete.topic.enable=true,那麼此時的刪除並不是真正的刪除,而是把topic標記為:marked for deletion

你可以通過命令:./bin/kafka-topics --zookeeper 【zookeeper server】 --list來檢視所有topic

此時你若想真正刪除它,可以如下操作:

(1)登入zookeeper客戶端:命令:./bin/zookeeper-client

(2)找到topic所在的目錄:ls /brokers/topics

(3)找到要刪除的topic,執行命令:rmr /brokers/topics/【topic name】即可,此時topic被徹底刪除。

另外被標記為marked for deletion的topic你可以在zookeeper客戶端中通過命令獲得:ls /admin/delete_topics/【topic name】,

如果你刪除了此處的topic,那麼marked for deletion 標記消失

zookeeper 的config中也有有關topic的資訊:ls /config/topics/【topic name】暫時不知道有什麼用

新建topic

./kafka-topics.sh --create --zookeeper ip:port --replication-factor 1 --partition 1 --topic【topic name】

檢視topic列表:

./kafka-topics.sh --list --zookeeper ip:port

kafka刪除topic資料

生產環境中,有乙個topic的資料量非常大。這些資料不是非常重要,需要定期清理。要求 預設保持24小時,某些topic 需要保留2小時或者6小時 主要有3個 1.基於時間 2.基於日誌大小 3.基於日誌起始偏移量 接下來,主要介紹基於時間的清除!kafka版本為 2.11 1.1.0 zk版本為 3...

Kafka徹底刪除topic

kafka預設僅做刪除標記,並沒有真實刪除,若要真實刪除topic server.properties新增 delete.topic.enable true,然後重啟 刪除測試 建立topic bin kafka topics.sh create zookeeper 127.0.0.1 2180 r...

kafka徹底刪除topic

刪除topic一般是下面這樣的,但是這樣是刪不掉的,只是標記為刪除,再次建立同名topic還是會報錯,topic已經存在.kafka topics.sh zookeeper mypc01 2181 mypc02 2181 mypc03 2181 kafka delete topic pet首先 se...