apache-kafka - 消费者配置 - 当我们将 enable.auto.commit 设置为 true 时，消费者何时提交偏移量

Question

我已将 enable.auto.commit 设置为 true 并将 auto.commit.interval.ms 设置为 10,000（即 10 秒）。现在我的问题是 - 如果消费者在第一次轮询时获得 100 条记录，并且侦听器正在处理一条一条的记录并且它在 10 秒内只处理了 80 条记录，它是否提交并将偏移量提前 80 或 100？

标签： apache-kafka

Answer 1

提交的偏移量将是轮询的数量，而不是处理的数量。

如果您想保证投票中的所有记录都已处理，您将需要禁用自动提交并自己执行