Kafka 确认与 Kafka 提交

Question

Kafka Acknowledgment和Kafka consumer commitSync()有什么区别

两者都用于手动偏移管理，希望两者同步工作。

请协助

Answer 1

使用 spring-kafka 时，Acknowledgment 是对详细消费者 API 的抽象，用于提交偏移量。

当你打电话时acknowledgement.acknowledge()；该操作取决于配置。使用 AckMode.MANUAL，提交将排队等待消费者稍后处理；使用 MANUAL_IMMEDIATE、commitSync()（默认或异步，取决于配置）被立即调用。