java - Kafka 自动提交在幕后是同步还是异步?

标签 java apache-kafka kafka-consumer-api

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

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

最佳答案

它实际上同时使用了两者!

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

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

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

关于java - Kafka 自动提交在幕后是同步还是异步?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54331939/

相关文章:

apache-kafka - Kafka 消费者不是从最新消息开始

java - 如何在 Android 中以编程方式查找当前正在运行的应用程序?

java开发和重新部署

apache-kafka - Spring Kafka - 遇到 "Magic v0 does not support record headers"错误

json - Spring-Kafka无法将AVRO GenericData.Record转换为Acknowledgment

python - Kafka python消费者组 session 超时

java - 使用 if 与单选按钮和文本一起归档?

java - 调用特定方法 onClickListener

azure - 将数据从 SQL Server 实时流式传输到 Azure 数据仓库

java - 消费者在重新启动之前无法从新创建的分区进行轮询