De ce contează max.in.flight.requests.per.connection
Această proprietate controlează pipelining-ul cererilor către broker. Cu idempotența activă (enable.idempotence=true), valoarea maximă sigură suportată de Kafka fără a risca reordonarea mesajelor este 5. Dacă idempotența ar fi oprită și valoarea este > 1, o cădere pe prima cerere urmată de succesul celei de-a doua ar putea inversa ordinea mesajelor pe disc.
Exemplu Concret: Configurare standard cu idempotență
Properties props = new Properties();
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, "true");
props.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, 5);
Întrebări & Exemple de Cod:
max.in.flight.requests.per.connection în KafkaAi o nelămurire despre utilizarea comenzii
max.in.flight.requests.per.connection în Kafkasau 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.