如果kafka enable.auto.commit=true
这是否意味着每 5 秒它就会在后台触发同步或异步操作来提交偏移量?
小间隔(2秒)会以某种方式影响延迟吗?
最佳答案
它实际上同时使用了两者!
使用异步调用 poll()
时定期发生的“常规”自动提交。请参阅1 .
但是,当消费者关闭或加入组时,也会发生自动提交,在这些情况下,它使用同步。请参阅2或3 .
关于使用低间隔自动提交影响延迟,在大多数情况下这是不太可能的。
关于java - Kafka 自动提交在幕后是同步还是异步?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54331939/