刪除kafka中的資料

2021-09-01 17:15:02 字數 737 閱讀 8962

刪除kafka中的資料。

：在kafka集群中刪除topic，當前topic被標記成刪除。

./kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --delete --topic t1205

在每台broker節點上刪除當前這個topic對應的真實資料。

rmr /brokers/topics/t1205

rmr /admin/delete_topics/t1205

總之：刪除kafka中的資料，一共需要刪除三處：分別是：

1、kafka集群中的資料，刪除的命令式：

./kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --delete --topic t1205
這時候只是標記為刪除了，還沒有真正地刪除，被標記為刪除預設停留時間是7天，達到真正地刪除還需要以下兩步：

2、去zookeeper中刪除資料，方式是開啟zookeeper客戶端，刪除topic資訊：

rmr /brokers/topics/t1205
這時候，之前在kafka集群中被標記為刪除的資訊還存在著，還需要去手動刪除，命令是：

rmr /admin/delete_topics/t1205
這時候，乙個kafka集群中的資訊就算全部刪除掉了。

kafka刪除topic資料

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

徹底刪除Kafka中的topic

1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeeper zookeeper server topic ...

徹底刪除Kafka中的topic

1 刪除kafka儲存目錄 server.properties檔案log.dirs配置，預設為 tmp kafka logs 相關topic目錄 2 kafka 刪除topic的命令是 bin kafka topics delete zookeeper zookeeper server topic ...