RoundRobinAssignor（轮询分区）

轮询分区策略是把所有partition和所有consumer线程都列出来，然后按照hashcode进行排序。最后通过轮询算法分配partition给消费线程。如果所有consumer实例的订阅是相同的，那么partition会均匀分布。

在我们的例子里面，假如按照 hashCode 排序完的topic-partitions组依次为T1-5, T1-3, T1-0, T1-8, T1-2, T1-1, T1-4, T1-7, T1-6, T1-9，我们的消费者线程排序为C1-0, C1-1, C2-0, C2-1，最后分区分配的结果为：

C1-0 将消费 T1-5, T1-2, T1-6 分区；

C1-1 将消费 T1-3, T1-1, T1-9 分区；

C2-0 将消费 T1-0, T1-4 分区；

C2-1 将消费 T1-8, T1-7 分区；

使用轮询分区策略必须满足两个条件

1. 每个主题的消费者实例具有相同数量的流

2. 每个消费者订阅的主题必须是相同的

RoundRobinAssignor（轮询分区）相关推荐

4.1.3 消费者轮询的流程
4.1.3 消费者轮询的流程按照消费者应用程序的示例,消费者订阅主题的下一步是"轮询".前面分析的准备t作(确保协调者存在,确保分配分区,更新拉取偏移量)都内置在轮询操作里,所以 ...
ajax循环输出,Ajax轮询 select循环输出
弹出层 .del{color:red} .addname{color:#337ab7} 款项名目操作 {$vo.name} 删除添加... $(".addname").on(&q ...
与现代传感器的接口：轮询ADC驱动程序
与现代传感器的接口:轮询ADC驱动程序 Interfacing with modern sensors: Polled ADC drivers 我们研究了在现代嵌入式应用程序中,开发人员应该如何创建一 ...
加权轮询算法PHP,PHP实现负载均衡的加权轮询方法分析
本文实例讲述了PHP实现负载均衡的加权轮询方法.分享给大家供大家参考,具体如下: 1. 负载均衡算法有哪些? 轮询法:将请求按顺序轮流地分配到后端服务器上,它均衡地对待后端的每一台服务器,而不关心服务 ...
VS2013自带的Browser Link功能引发浏览localhost网站时不停的轮询
浏览localhost网站时候不管你打开那个页面它都会不停的轮询.据悉这是VS2013自带的Browser Link功能,里面用到SignalR机制什么是Browser Link功能,什么是Sign ...
jQuery 一次定时器_干货 | 小论定时器玩法(时间轮询法)
EEWORLD 电子资讯犀利解读技术干货每日更新经常来说,对于一些不复杂的单片机应用,而且对于内存和存储要求比较严格,又需要多分时去处理一些指定的任务,在无法使用RTOS的情况下,使用一个硬件 ...
一个非常简单的 ASP.NET MVC 示例：长轮询（又叫：反向 AJAX，英文名：Comet）实现...
关于长轮询(又叫:反向 AJAX,英文名:Comet)的介绍,请查看:反向Ajax,第1部分:Comet介绍下面是代码实现: UI: <p><input type="b ...
用了这么久配置中心，还不知道长轮询是什么？
前言传统的静态配置方式想要修改某个配置时,必须重新启动一次应用,如果是数据库连接串的变更,那可能还容易接受一些,但如果变更的是一些运行时实时感知的配置,如某个功能项的开关,重启应用就显得有点大动干戈 ...
哈希一致性、哈希取余、自定义轮询分片的比较
2019独角兽企业重金招聘Python工程师标准>>> 一.自定义轮询分片按照上图所示,自己写一段逻辑,根据客户端请求循环写入不同Redis服务器优点: 理解简单数据分布平均 ...

RoundRobinAssignor（轮询分区）

RoundRobinAssignor（轮询分区）相关推荐

最新文章

热门文章