1. 程式人生 > >【分散式】--訊息kafka保證消順序一致性(358)

【分散式】--訊息kafka保證消順序一致性(358)

在kafka中,同一個topic,被分成了多個partition,這多個partition之間是互相獨立的。

之所以要分成多個partition,是為了提高併發度,多個partition並行的進行傳送/消費,但這卻沒有辦法保證訊息的順序問題。

一個解決辦法是,一個topic只用一個partition,但這樣很顯然限制了靈活性。

還有一個辦法就是,所有傳送的訊息,用同一個key,這樣同樣的key會落在一個partition裡面。