spring kafka消费类图之间关系

image.png

springkafka自定义三个队列，一个消费记录队列 recordsToProcess
一个acks确认队列
一个seeks,定位偏移向量队列
springkafka每次从kafka中拉取消息放到recordsToProcess队列里，如果队列满了，暂停从kafka中拉取消息，等recordsToProcess消费完了,再继续拉取消息放入recordsToProcess 。
在确认时，判断是否是手动立即确认，如果是，调用消费者ack方法确认，如果不是判断根据指定的是否是timeAck策略，来批量的进行确认。

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

推荐阅读更多精彩内容