一个kafka消费者是如何同时消费一个topic的多个分区的数据的?是根据不同的分区的积压数据量还是轮询消费的呢?网上简单查了查没看到相关的说明,望哪位大佬指点下
标签:
相关文章
- 敏捷开发在互联网时代里的价值
- PL2586|替代FE1.1S|替代MA8601|USB2.0HUB集线器芯片|旺玖
- 力软快速开发平台,帮助中小企业躲过数字化“踏浪出海”的“暗礁”
- 软件开发:站在风口上的低代码
- TYPEC转HDMI方案|TYPEC扩展坞方案|CS5265设计4K60HZ TYPEC转HDMI方
- DP转HDMI2.0|DP转HDMI和VGA输出|CS5262AN方案应用|瑞奇达CS5262设计电
- Capstone瑞奇达|台湾瑞奇达|一级代理商|台湾瑞奇达科技有限公司
- CH7511B替代方案|CS5211设计方案|CS5211替代CH7511B|eDP转LVDS转接板
1.消费组启动时候需要指定消费者名称
2.对于多个消费者客户端使用同一个消费组去消费同一个topic时,会在消费者客户端加入后为其分配topic分区,具体方式是对消费者排序后将每个分区依次分配给消费者,此时分区与消费者的对应关系是确定好的
3.消费者加入或下线会触发重平衡,重新给所有消费者分配分区
4.你可以指定消费topic的某个分区
5.消费组内消费者数量与topic分区关系:
消费者数量<topic分区数:会有消费者被分配的分区多余1
消费者数量>topic分区数:会有消费者不能分配到分区
消息进入到分区,是根据分区规则进入到相应的分区
消费的时候同样是也根据这个规则到相应的分区消费
就跟分布式数据库,数据进入到不同的库,然后取数据的时候,根据规则,从指定的库读取数据
轮询的效率太低