From: Kai Moritz <kai@juplo.de>
Date: Sun, 3 Apr 2022 05:45:15 +0000 (+0200)
Subject: Delivery-Timeout für den REST-Producer herabgesetzt
X-Git-Tag: acks-KAPUTT-DEPRECATED~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=13ca75e4fc7db1f65903609a566dcbcde2d89214;p=demos%2Fkafka%2Ftraining

Delivery-Timeout für den REST-Producer herabgesetzt

* 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...
---

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());