kafka對消費者分配分區規則(Java源碼)

在上一篇 kafka topic消息分配partition規則(Java源碼) 我們對生產者產生的消息分配partition規則進行了分析,那麼本章我們來看看消費者是怎麼樣分配partition的。   kafka 爲了保證同一類型的消息順序性(FIFO),一個partition只能被同一組的一個consumer綁定消費,不同組的consumer可以綁定同一個partition進行重複消費。但是一
相關文章
相關標籤/搜索