kafka 分布式(不是單機)的情況下,如何保證消息的順序消費?


Kafka 分布式的單位是 partition,同一個 partition 用一個 write ahead log 組織

所以可以保證 FIFO 的順序不同 partition 之間不能保證順序但是絕大多數用 

戶都可以通過 message key 來定義因為同一個 key  message 可以保證只發 

送到同一個 partition。

Kafka 中發送 1 條消息的時候可以指定(topic, partition, key) 3 個參數

partiton  key 是可選的如果你指定了 partition,那就是所有消息發往同 1

 partition,就是有序的並且在消費端,Kafka 保證,1  partition 只能被 

1  consumer 消費或者你指定 key(比如 order id),具有同 1  key  

所有消息會發往同 1  partition。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM