Odczyt wszystkich wiadomości z Kafki

Odczyt wszystkich wiadomości z Kafki
BI
  • Rejestracja: dni
  • Ostatnio: dni
  • Postów: 72
0

Witam
Korzystam z

Kopiuj
@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?

BI
  • Rejestracja: dni
  • Ostatnio: dni
  • Postów: 72
0

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

99xmarcin
  • Rejestracja: dni
  • Ostatnio: dni
  • Postów: 2420
0

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

Zarejestruj się i dołącz do największej społeczności programistów w Polsce.

Otrzymaj wsparcie, dziel się wiedzą i rozwijaj swoje umiejętności z najlepszymi.