kafka 的 Log Compaction 簡單使用測試

最近公司需要對存儲在kafka的日誌做一些特殊處理，要求對每個設備只存儲最後一條日誌數據，也就是需要根據key進行日誌更新和保留，刪除重複的key日誌數據，因此想到了kafka的Log Compaction。 通過kafka官網能瞭解到Log Compaction是什麼？能做什麼？官網介紹的使用其實很簡單，只需進行參數配置即可。但是具體的實施並不那麼簡單，我在測試中也是出現了很多問題，反覆琢磨後才

>>阅读原文<<