消费者组是逻辑上的一个消费者,是由一个或多个消费者实例组成,具有可扩展性和可容错性,消费者组内的消费者共享一个GroupId组成;组内每个消费者负责消费不同分区数据,并行消费数据;当组内一个消费者挂了之后 , 其它消费者要自动承担它的消费任务 - 组内再平衡 。
触发再平衡消费成员与Broker分区保持心跳连接,或者消费成员处理消息时间过长,会被认为此消费者需要被移除,触发组内消费成员任务再分配 。以下配置任其一条件触发再平衡:
- # 心跳连接超时的 移除条件(建议45秒)
- session.timeout.ms
- # 消息处理超时的 移除条件(建议5分钟)
- max.poll.interval.ms
-
- # 再平衡策略配置项(可多策略组合)
- partition.assignment.strategy = Range | RoundRobin | Sticky | CooperativeSticky
- Range:单个Topic内的重新平均分配
- RoundRobin:所有Topic的全部消费者 , 一起重新分配
- Sticky:一次小范围重新分配;仅调整需要的,避免大规模重新分配
- CooperativeSticky:可多次小范围重新调整,直至最终效果
- 增加分区,增加消费者,两者一一对应起来,并行消费
- 调整一次最多拉取的消息条数(500条)
- 调整单次抓取的数据最大容量(50M)
推荐阅读
- 我的父亲作文600字初中作文 关于我的父亲写人作文600字
- 我的老父亲优秀学生作文5篇
- 我的父亲作文600字初中优秀作文 我的父亲初二优秀作文600字范文
- 我的父亲600字优秀作文初中 描写我的父亲初中600字作文
- 我的世界手机版紫珀台阶怎么获得
- 关于朋友圈的句子短句子 发朋友圈的句子短句子
- 主播感谢守护的句子 感谢守护我的句子
- qq查看特别关心我的人数 qq查看特别关心我的人
- 我的心情为什么总是很忧郁 为什么我的心情总是忧郁?
- 抖音流行的短句子关于友情 抖音流行的短句子