dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
KAFKA Toate comenzile Apache Kafka

max.poll.records în Consumatorul Kafka în Apache Kafka

Configurații critice pentru Consumator Kafka 0.10+ Q&A / Distribuie cod

Limitează numărul maxim de înregistrări returnate la o singură invocare a metodei poll().

Sintaxă 
props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 500);

Optimizarea timpului de procesare cu max.poll.records

Metoda poll() extrage un lot de mesaje din bufferul local. Dacă procesarea fiecărui mesaj implică operațiuni lente (apeluri REST externe, scrieri în SQL), un lot prea mare (implicit 500) poate dura mai mult decât timpul permis de max.poll.interval.ms, declanșând o rebalansare nedorită. Reducerea valorii la 50 sau 100 oferă predictibilitate.

Exemplu Concret: Limitare pentru procesare lentă
Properties props = new Properties();
props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 50); // maxim 50 de mesaje per iterație
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: max.poll.records în Consumatorul Kafka

Ai o nelămurire despre utilizarea comenzii max.poll.records în Consumatorul Kafka sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.