【问题标题】:does Kafka auto commit is sync or async under the hood?Kafka 自动提交是同步还是异步?
【发布时间】:2019-06-17 07:41:37
【问题描述】:

如果卡夫卡enable.auto.commit=true 这是否意味着每 5 秒它会在后台触发同步或异步操作以提交偏移量?

小间隔(2 秒)会以某种方式影响延迟吗?

【问题讨论】:

标签: java apache-kafka kafka-consumer-api


【解决方案1】:

实际上两者都用!

使用异步调用poll() 时定期发生的“常规”自动提交。见1

但是,当消费者关闭或加入组时也会发生自动提交,在这些情况下,它使用同步。请参阅23

关于使用影响延迟的低间隔自动提交,在大多数情况下不太可能。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2019-01-17
    • 2017-06-22
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多