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

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

目前没有机制聚合多个确认。

您可以保存确认实例，并在准备就绪时逐个确认它们（确保按正确的顺序执行）。