526互联

java——spring boot集成kafka——kafka集群中Rebalance机制

发布时间 2023-04-02 15:35:30作者: 小白龙白龙马

 

 

 

 

前提是：消费者没有指明分区消费。当消费组⾥消费者和分区的关系发⽣变化，那么就会触发rebalance机制。

 

这个机制会重新调整消费者消费哪个分区。

 

在触发rebalance机制之前，消费者消费哪个分区有三种策略：


1、range：通过公示来计算某个消费者消费哪个分区
2、轮询：⼤家轮着消费
3、sticky：在触发了rebalance后，在消费者消费的原分区不变的基础上进⾏调整。