【发布时间】:2020-03-04 13:25:57
【问题描述】:
我已将 enable.auto.commit 设置为 true 并将 auto.commit.interval.ms 设置为 10,000(即 10 秒)。现在我的问题是 - 如果消费者在第一次轮询时获得 100 条记录,并且侦听器正在处理一条一条记录并且它在 10 秒内只处理了 80 条记录,它是否提交并将偏移量提前 80 或 100?
【问题讨论】:
标签: apache-kafka
我已将 enable.auto.commit 设置为 true 并将 auto.commit.interval.ms 设置为 10,000(即 10 秒)。现在我的问题是 - 如果消费者在第一次轮询时获得 100 条记录,并且侦听器正在处理一条一条记录并且它在 10 秒内只处理了 80 条记录,它是否提交并将偏移量提前 80 或 100?
【问题讨论】:
标签: apache-kafka
提交的偏移量将是轮询的数量,而不是处理的数量。
如果您想保证投票中的所有记录都已被处理,您需要禁用自动提交并自行执行
【讨论】: