關於kafka中消費者的分區分配策略

在說分區分配之前我們先要強調一下consumer採用pull（拉）模式從broker中讀取數據 。因爲push（推）模式很難適應消費速率不同的消費者，因爲消息發送速率是由broker決定的。它的目標是儘可能以最快速度傳遞消息，但是這樣很容易造成consumer來不及處理消息，典型的表現就是拒絕服務以及網絡擁塞。 下面我們來看一下如下所示的分區和消費者組的圖 你可能會想這個圖中的消費者會消費到主題中

>>阅读原文<<