Kafka入門之consumer--rebalance流程

  重平衡(rebalance) 舊版本Kafka依託於Zk進行rebalance,新版本consumer使用了Kafka內置的一個全新的組協調協議。對於每個組而言,Kafka的某個broker會被選舉爲組協調者(coordinator)。 觸發條件: 1.組成員發生變更。 2.組訂閱topic數發生變更。比如使用基於正則表達式的訂閱,當匹配正則表達式的新topic被創建時則會觸發rebalanc
相關文章
相關標籤/搜索