Grokking Kafka and Event-Driven Architecture
Vote

0% completed

​

Idempotent Producers

These lines ask a Kafka 4.4 producer configuration, built with nothing but a server address and two serializers, which delivery settings it will use:

ProducerConfig defaults = new ProducerConfig(base());
System.out.println("enable.idempotence=" + defaults.getBoolean("enable.idempotence"));
System.out.println("acks=" + defaults.getString("acks"));
System.out.println("max.in.flight.requests.per.connection=" + defaults.getInt("max.in.flight.requests.per.connection"));
System.out.println("retries=" + defaults.getInt("retries"));
enable.idempotence=true
acks=-1
max.in.flight

.....

.....

.....

Like the course? Get enrolled and start learning!

Reading Progress

0%

Vote for new content