1.概述 最近和一些同學交流的時候反饋說，在面試Kafka時，被問到Kafka組件組成部分、API使用、Consumer和Producer原理及作用等問題都能詳細作答。但是，問到一個平時不注意的問題，就是Kafka的冪等性，被卡主了。那么，今天筆者就為大家來剖析一下Kafka的冪等性原理及實現 ...

這幾天很忙，但是我現在給我的要求是一周至少要出一篇文章，所以先拿這篇筆記來做開胃菜，源碼分析估計明后兩天應該能寫一篇。給自己加油~，即使沒什么人看。 可靠性 如何保證消息不丟失 Kafka只對“已提交”的消息（committed message）做有限度的持久化保證。 已提交的消息 ...

項目要求使用kafka的事務，遇到了一些問題，研究了下kafka的事務機制記錄一下。 kafka事務是為了實現: Exactly Once即正好一次語義 操作的原子性 有狀態操作的可恢復性     kafka的冪等性可以實現Exactly Once語義，冪等性提供 ...

【EFCORE筆記】使用事務 默認事務行為 默認情況下，如果數據庫提供程序支持事務，單個 SaveChanges() 調用中的所有變更都會在一個事務中被提交。如果其中任何一個變更失敗了，那么事務就會回滾，沒有任何變更會被應用到數據庫。這意味着 ...

概念 　　我們實際系統中有很多操作，是不管做多少次，都應該產生一樣的效果或返回一樣的結果。 　　例如：前端重復提交選中的數據，應該后台只產生對應這個數據的一個反應結果。等等很多重要的情況，這些邏輯都需要冪等的特性來支持。 實現方案 數據庫唯一索引，防止新增臟數據 ...

Kafka 是LinkedIn 開發的一個高性能、分布式的消息系統. 用途：廣泛用於日志收集、流式數據處理、在線和離線消息分發等場景。 1. Kafka 將消息流按Topic 組織，保存消息的服務器稱為Broker，消費者可以訂閱一個或者多個Topic。為了均衡負載，一個Topic 的消息又可 ...

1、概念 冪等性, 通俗的說就是一個接口, 多次發起同一個請求, 必須保證操作只能執行一次 比如: 訂單接口, 不能多次創建訂單 支付接口, 重復支付同一筆訂單只能扣一次錢 支付寶回調接口, 可能會多次回調, 必須處理重復回調 普通表單提交接口, 因為網絡超時等原因多次點擊提交, 只能 ...

1. Kafka的事務和 Exactly Once Kafka 中的事務，它解決的問題是，確保在一個事務中發送的多條消息，要么都成功，要么都失敗。注意，這里面的多條消息不一定要在同一個主題和分區中，可以是發往多個主題和 分區的消息。Kafka 的這種事務機制，單獨來使用的場景不多。更多 ...