【5分钟背八股】kafka的rebalance机制是什么?
2022-06-05 本文已影响0人
废柴程序员
消费者分区分配策略
-
Range 范围分区(默认的)
-
RoundRobin 轮询分区
-
Sticky策略
触发 Rebalance 的时机
Rebalance 的触发条件有3个。
- 组成员个数发生变化。例如有新的 consumer 实例加入该消费组或者离开组。
- 订阅的 Topic 个数发生变化。
- 订阅 Topic 的分区数发生变化。
Coordinator协调过程
-
消费者如何发现协调者
-
消费者如何确定分配策略
-
如果需要再均衡分配策略的影响