工作中因為各種原因, 例如topic中消息堆積的太多,或者kafka所在磁盤空間滿了等等,可能需要徹底清理一下kafka topic,那么如何徹底刪除topic?方法一(配置delete.topic.enable=true) 修改kafaka配置文件server.properties, 添加 ...
前提 按照前一篇文章,配置了kafka。但是研發刪除topic還是標記marked for deletion。 過程 .首先刪除各個kafka節點的數據目錄的該topic的數據,檢查發現已經被刪除。 .連接zookeeper,徹底刪除topic 此處以t f為例 ,需要刪除zookeeper中三個地方 rmr brokers topics t f 刪除t f的patition rmr config ...
2022-02-26 11:20 0 837 推薦指數:
工作中因為各種原因, 例如topic中消息堆積的太多,或者kafka所在磁盤空間滿了等等,可能需要徹底清理一下kafka topic,那么如何徹底刪除topic?方法一(配置delete.topic.enable=true) 修改kafaka配置文件server.properties, 添加 ...
手動: 刪除kafka存儲目錄(server.properties文件log.dirs配置,默認為"/tmp/kafka-logs")相關topic目錄 刪除zookeeper "/brokers/topics/"目錄下相關topic節點 命令+手動 ...
概述 在平時對kafka的運維工作中,我們經常會由於某些原因去刪除一個topic,比如這個topic是測試用的,生產環境中需要刪除。或者我想擴容topic的同時,這個topic中的數據我不想要了,這時候刪除topic,增加broker,再重新創建topic就會是比較簡單的方法。但是kafka ...
一、概述 生產環境中,有一個topic的數據量非常大。這些數據不是非常重要,需要定期清理。 要求:默認保持24小時,某些topic 需要保留2小時或者6小時 二、清除方式 主要有3個: 1. 基於時間 2. 基於日志大小 3. 基於日志起始偏移量 詳情,請參考鏈接 ...
------------恢復內容開始------------ 最近測試環境的kafkaTopic太多太亂,大部分測試用的topic已經沒有用了,就想着刪掉。查閱了網上博客資料之后進行了操作。 1.有說在kafka的server配置文件中加上delete.topic.enable=true ...
3、Kafka 刪除topic的命令是: ./bin/kafka-topics --dele ...
1、刪除kafka存儲目錄(server.properties文件log.dirs配置,默認為"/tmp/kafka-logs")相關topic目錄。 2、可以通過bin下面的 bin/kafka-topics.sh #如果kafaka啟動時加載的配置文件中 ...
如果只是用kafka-topics.sh的delete命令刪除topic,會有兩種情況: 如果當前topic沒有使用過即沒有傳輸過信息:可以徹底刪除 如果當前topic有使用過即有過傳輸過信息:並沒有真正刪除topic只是把這個topic標記為刪除(marked ...