当前位置: 首页 > 知识库问答 >
问题:

使用者配置-当我们将enable.auto.commit设置为true时,使用者提交何时偏移

太叔马鲁
2023-03-14

我已经将enable.auto.commit设置为true,并将auto.commit.interval.ms设置为10,000(即10秒)。现在我的问题是--如果使用者在第一次轮询时得到100条记录,而监听器正在处理一条一条的记录,而它在10秒内只处理了80条记录,它是提交并将偏移提前80还是100?

共有1个答案

夏侯和韵
2023-03-14

提交的偏移量将是轮询的金额,而不是处理的金额。

如果您想要确认轮询中的所有记录都已处理,那么您需要禁用自动提交并自己执行

 类似资料: