四个分区分配策略:Range,Roundrobin,Sticky,CooperativeSticky
kafka 消费者 分区分配策略:Range(范围)
分区分配策略:Range(范围),Range是针对每个topic进行分区分配的,分别对分区和消费排序,通过 分区数/消费者数 来决定每个消费者应该消费几个分区,除不尽则前面几个消费者会多消费1个分区。
如果有多个topic,并且不能均匀分配,则前面的消费者会消费比较多的分区,所以Range分配会引起数据倾斜。
kafka 消费者 分区分配策略:Roundrobin(轮询)
分区分配策略:Roundrobin(轮询),Roundrobin是针对集群中所有topic的所有分区和所有消费者进行分区分配。
kafka 消费者 分区分配策略:Sticky(粘性)
分区分配策略:Sticky(粘性),Sticky分配是尽量均匀的随机分配,尽量保持原有分配的分区不变化。
kafka 消费者 分区分配策略:CooperativeSticky(协作粘性)