天天看點

【5分鐘背八股】kafka的rebalance機制是什麼?

消費者分區配置設定政策

  • Range 範圍分區(預設的)
  • RoundRobin 輪詢分區
  • Sticky政策

觸發 Rebalance 的時機

  • 組成員個數發生變化。例如有新的 consumer 執行個體加入該消費組或者離開組。
  • 訂閱的 Topic 個數發生變化。
  • 訂閱 Topic 的分區數發生變化。

Coordinator協調過程

  • 消費者如何發現協調者
  • 消費者如何确定配置設定政策
  • 如果需要再均衡配置設定政策的影響