带有多个轮询记录的手动确认模式与 spring kafka

Question

我正在使用 spring kafka 来使用来自 kafka 的记录。我将 max.poll.records 设置为 300，启用自动提交设置为 false，确认模式设置为 MANUAL。

我想知道如果说 100 条记录得到了正确处理，并且我已经在我的 kafkaListener 中使用 Acknowledgment.acknowledge 确认了每一条记录，现在无法处理我没有处理的第 101 条记录确认并正确处理所有剩余记录（即从第 102 条到第 300 条）。 1. 现在提交期间会发生什么？ 2. 我会再次收到同一批次（第 1 至第 300 批），还是从（第 101 批）或第 300 批之后的记录。

提前致谢。

Answer 1

使用 Kafka，不确认单个记录，仅确认分区内消费者组的偏移量。因此，承认较晚的记录将隐含承认较早的记录。