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

linger.ms: Maximizarea Debitul de Transmisie în Apache Kafka

Configurații critice pentru Producător Kafka 0.8+ Q&A / Distribuie cod

Introduce o întârziere artificială minoră pentru a permite gruparea mai multor mesaje în același lot de scriere.

Sintaxă 
props.put(ProducerConfig.LINGER_MS_CONFIG, 20); // timp în milisecunde

Ce face linger.ms

Implicit, linger.ms=0, ceea ce înseamnă că producătorul va expedia lotul de îndată ce conexiunea de rețea este disponibilă, chiar dacă lotul conține un singur mesaj. Setând linger.ms=10 sau 20, producătorul așteaptă câteva milisecunde pentru a lăsa timp noilor mesaje să se acumuleze în același pachet, crescând rata de comprimare și reducând drastic numărul de cereri I/O.

Exemplu Concret: Configurare cuplată linger.ms și batch.size
Properties props = new Properties();
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 65536); // 64 KB
props.put(ProducerConfig.LINGER_MS_CONFIG, 20);      // 20 ms pauză
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: linger.ms: Maximizarea Debitul de Transmisie

Ai o nelămurire despre utilizarea comenzii linger.ms: Maximizarea Debitul de Transmisie 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.