From 13ca75e4fc7db1f65903609a566dcbcde2d89214 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 3 Apr 2022 07:45:15 +0200 Subject: [PATCH] =?utf8?q?Delivery-Timeout=20f=C3=BCr=20den=20REST-Produce?= =?utf8?q?r=20herabgesetzt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Der Timeout für `delivery.timeout.ms` wurde von 2 Minuten auf 20 Sekunden heruntergesetzt * Grund: Die HTTP-Verbindungen der Clients laufen nach 30 Sekunden in den Default-Timeout, so dass die Fehler sonst nicht sichtbar werden! * Achtung: Parallel musste dafür `request.timeout.ms` auf 10 Sekunden herabgesetzt werden, da `delivery.timeout.ms` größer oder gleich `request.timeout.ms` + `linger.ms` sein muss! * Die 10s Spiel zwischen `delivery.timeout.ms` und `request.timeout.ms` werden für die Übungen benötigt, in denen mit `linger.ms` experimentiert werden soll... --- src/main/java/de/juplo/kafka/RestProducer.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java index 19f70ba..dea49f0 100644 --- a/src/main/java/de/juplo/kafka/RestProducer.java +++ b/src/main/java/de/juplo/kafka/RestProducer.java @@ -34,6 +34,8 @@ public class RestProducer props.put("client.id", properties.getClientId()); props.put("acks", properties.getAcks()); props.put("batch.size", properties.getBatchSize()); + props.put("delivery.timeout.ms", 20000); // 20 Sekunden + props.put("request.timeout.ms", 10000); // 10 Sekunden props.put("linger.ms", properties.getLingerMs()); props.put("compression.type", properties.getCompressionType()); props.put("key.serializer", StringSerializer.class.getName()); -- 2.20.1