一次提交多个批次的偏移量

Question

我有一个 kafkalistener，它可以一次收听一批消息，如下所示

@KafkaListener(topics = "topicName", container = "conatainer_name")
public void listenEvents(@payload List<ConsumerRecord<String,String>> records, Acknowledgement ack) {
    process(records);
    ack.acknowledge();//committing offsets
}

我的问题，有没有办法监听多批消息并只提交一次。例如，如果我在 kafka 主题中有 1000 条消息，我想以 10 批的形式一次监听 100 条消息并提交偏移量处理10批消息后。

Answer 1

目前没有聚合多个Acknowledgments 的机制。

您可以保存 Acknowledgment 实例，并在准备好时单独确认它们（确保以正确的顺序执行它们）。