apache-kafka - Kafka 确认与 Kafka 提交

Question

Kafka Acknowledgement 和 Kafka 消费者 commitSync() 有什么区别

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

请协助

标签： apache-kafkakafka-consumer-apispring-kafka

Answer 1

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

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