天天看点

【5分钟背八股】kafka的rebalance机制是什么?

消费者分区分配策略

  • Range 范围分区(默认的)
  • RoundRobin 轮询分区
  • Sticky策略

触发 Rebalance 的时机

  • 组成员个数发生变化。例如有新的 consumer 实例加入该消费组或者离开组。
  • 订阅的 Topic 个数发生变化。
  • 订阅 Topic 的分区数发生变化。

Coordinator协调过程

  • 消费者如何发现协调者
  • 消费者如何确定分配策略
  • 如果需要再均衡分配策略的影响