在kafka中启用自动提交并触发轮询时,是否在读取新记录之前或之后提交(最大存在)偏移量?在这里,我们可以假设自动提交间隔需要自动提交这个轮询事件。如果问题不太清楚,请告诉我。谢谢。
vltsax251#
在轮询时,如果自动提交间隔已过,则从上一次轮询返回的最后一条消息的偏移量将在获取新记录之前提交。但是,如果提交失败,处理将继续进行,稍后将重新尝试提交。见上一个问题:Kafka抵消管理
1条答案
按热度按时间vltsax251#
在轮询时,如果自动提交间隔已过,则从上一次轮询返回的最后一条消息的偏移量将在获取新记录之前提交。但是,如果提交失败,处理将继续进行,稍后将重新尝试提交。
见上一个问题:Kafka抵消管理