Odczyt wszystkich wiadomości z Kafki

0

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?

0

@BartoszCoyote: dzięki, o to mi chodziło, działa :)

0

Tylko pamiętaj że "wszystkie" bardzo zależy od ustawionej na topicu retencji.

1 użytkowników online, w tym zalogowanych: 0, gości: 1, botów: 0