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

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