kafra技术内幕：消费者初始化(scala)（三）

2018-3-30 13:00 |来自: 互联网 379 0

摘要: 架构师（JiaGouX）我们都是架构师！ 3) PartitionAssignor 将可用的partitions以及消费者线程排序, 将partitions处于线程数,表示每个线程(不是消费者数量)平均可以分到几个partition. 如果除不尽,剩余的会分给前面 ...

架构师（JiaGouX）

我们都是架构师！

将可用的partitions以及消费者线程排序, 将partitions处于线程数,表示每个线程(不是消费者数量)平均可以分到几个partition.

如果除不尽,剩余的会分给前面几个消费者线程. 比如有两个消费者,每个都是两个线程,一共有5个可用的partitions:(p0-p4).

每个消费者线程(一共四个线程)可以获取到至少一共partition(5/4=1),剩余一个(5%4=1)partition分给第一个线程.

最后的分配结果为:p0 -

声明：文章版权归原作者所有部分文章转自互联网如有侵权请联系 [邮箱地址] 删除

上一篇：为什么说每个程序员都应该有台Mac电脑下一篇：kafra技术内幕：消费者初始化(scala)（二）

相关分类