batch.size în Producătorul Kafka în Apache Kafka

Dimensiunea maximă a memoriei alocate per partiție pentru acumularea mesajelor într-un singur pachet de rețea.

Sintaxă
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 65536); // în octeți (ex: 64 KB)

Cum influențează batch.size performanța

Producătorul Kafka grupează mesajele destinate aceleiași partiții într-un buffer comun. Când bufferul atinge dimensiunea setată în batch.size (implicit 16384 bytes / 16 KB), pachetul este trimis imediat pe firul de execuție de rețea. Mărirea acestei valori la 64KB sau 128KB crește semnificativ debitul (throughput) în aplicații cu volum mare.

Exemplu Concret: Alocare batch de 64 KB
Properties props = new Properties();
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 64 * 1024); // 65536 bytes
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: batch.size în Producătorul Kafka

Ai o nelămurire despre utilizarea comenzii batch.size în Producătorul 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.