【问题标题】:Consumer configurations - when does the consumer commit offset when we set enable.auto.commit to true消费者配置 - 当我们将 enable.auto.commit 设置为 true 时,消费者何时提交偏移量
【发布时间】:2020-03-04 13:25:57
【问题描述】:

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

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

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

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

    【讨论】:

      猜你喜欢
      • 2020-03-05
      • 1970-01-01
      • 1970-01-01
      • 2019-04-04
      • 2021-11-10
      • 1970-01-01
      • 2018-06-14
      • 1970-01-01
      • 2022-11-13
      相关资源
      最近更新 更多