kafka測定刪除topic及其內容

2021-07-04 22:11:47 字數 781 閱讀 2909

要使topic可以刪除,首先在你的config/server.properties檔案末尾中新增這一項:

delete.topic.enable=true

1、/bin/kafka-topic --delete --zookeeper 《主機名》:《埠號(預設為2181)> --topic

2、kafka不一定馬上就刪除所有資料,找到config/server.properties檔案中log.dirs所設定的目錄,刪掉所有《要刪topic>-《數字》,數字是指topic的分割槽數

3、修改步驟2目錄下的recovery-point-offset-checkpoint和replication-offset-checkpoint,以recovery-point-offset-checkpoint檔案為例,刪掉所有跟《要刪topic>有關的行,注意你所刪的行數,其實記住其分割槽數就可以可,然後將第二行的數子修改為「原來數字減去刪掉的行數」。如圖1所示,本來有個druidtopic的topic,分割槽數為1,因此只有druidtopic 0 0這一行,將其刪掉, 並將第二行的1修改為0,如圖2.

4、按照步驟3的方式修改檔案replication-offset-checkpoint

kafka 徹底刪除 topic 及資料

預設情況,當我們刪除 topic 並不會真正刪除,只是把佇列標記為 marked for deletion 如果我們要徹底刪除 topic 及資料,可採用一下方法 方法一 修改 kafka conf server.properties,增加 delete.topic.enable true,然後重啟...

kafka刪除新建topic

原理翻譯可參考 刪除kafka的topic,參照 1 刪除kafka儲存目錄 server.properties檔案log.dirs配置,預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeepe...

kafka刪除topic資料

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