kafka消费者提交commit超时造成rebalance

session.timeout.ms
单独线程进行心跳检测的间隔

max.poll.records
一次poll()拉取最多返回多少消息，默认是500条。

max.poll.interval.ms
两次poll()之间的最大间隔，默认是5分钟。
如果间隔大于此值，就会触发rebalance。

如果max.poll.records返回了500条，而消费者处理500条大于5分钟，就会发生rebalance。
因为没有提交Commit，消费者reblance后，从起始处重新拉取消息，从而导致重复消费。

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容