Witam
Korzystam z
@KafkaListener(topics = "myTopic")
public void consume(ConsumerRecord<String, MyDTO> record, Acknowledgment acknowledgment) {
....
}
Czy w takiej sytuacji jest jakiś sposób aby pobrać wszystkie oczekujące wiadomości a nie tylko pojedynczo?