我是 kafka 的新手，對事件洗掉很感興趣。Kafka 不會洗掉主題中的事件。但在保留一段時間后將其洗掉。
例如，我在 dotnet 核心平臺上有一個消費者和一個生產者應用程式。生產者放入Order資料，消費者獲取并保存到資料庫。但是主題沒有被洗掉。如果消費者應用程式重新啟動，它會從零開始并復制資料庫記錄嗎？我們怎樣才能防止這種情況發生？
uj5u.com熱心網友回復：
查看偏移量的檔案：
此偏移量充當該磁區內記錄的唯一識別符號，并且還表示消費者在磁區中的位置。
...
提交位置是已安全存盤的最后一個偏移量。如果行程失敗并重新啟動，這是消費者將恢復到的偏移量。
確保消費者正在提交偏移量，并且在重新啟動時，它將使用相同的偏移量來繼續使用主題。
轉載請註明出處，本文鏈接：https://www.uj5u.com/qianduan/524205.html
標籤：。网阿帕奇卡夫卡
上一篇：CsvHelper：在將字串加載到ClassMap之前修改字串？
下一篇：我在回傳計數中收到錯誤提示“無法將型別'int'隱式轉換為'Microsoft.AspNetCore.Mvc.IActionResult'”