kafka消费者重平衡是什么？怎么避免？
消费者重平衡是指主题下的分区怎么分配给消费者的过程。下面这个图可以看出该过程：原来有2个消费者，3个分区，其中一个消费者肯定就的处理2个分区了。那么当新加入消费者时，则每个消费者就只处理一个分区了。处理这个分区过程的叫协调者，协调者就在broker端。
当发生重平衡时，所有消费者都不能收到消息，所以发生这个过程是非常严肃的。
什么时候会发生重平衡？
- 新的消费者加入。
- 消费者主动离开。比如取消对主题的订阅。
- 消费者崩溃离开。比如网络延迟导致心跳一直没收到。
- 主题分区数发生变更。
怎么避免消费者重平衡？
有几个参数可以重点看下：
- session.timeout.ms=10 协调者超过10秒没有收到消费者的请求则认为消费者已经下线。
- heartbeat.interval.ms 心跳频率。消费者间隔多久发送心跳。
- max.poll.interval.ms 消费者两次调用poll的时间间隔，默认是5分钟。超过5分钟则认为上次拉去的消息一直没消费完成，也被认为需要重平衡。
- max.poll.records=500 默认单次最大拉取条数为500。如果一次拉取太多数据，会导致超时了还没处理完成。
主题有3个分区，那么消费者组员数应该也是3个才算合理的分配，多出的组员将无法分配消费分区是种浪费。消费者对应机器数最好是固定的，避免频繁加减节点带来的重平衡。
原文地址：https://blog.csdn.net/zzy916853616/article/details/136410313
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！