代码之家  ›  专栏  ›  技术社区  ›  rayman

kafka auto-commit是同步的还是异步的?

  •  1
  • rayman  · 技术社区  · 6 年前

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

    小间隔(2秒)能否影响延迟?

    1 回复  |  直到 6 年前
        1
  •  3
  •   Mickael Maison    6 年前

    它实际上使用两者!

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

    但是,当使用者关闭或加入组时,也会发生自动提交,在这些情况下,它使用的是同步的。见 2 3 .

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