`delivery.timeout.ms` und `request.timeout.ms` noch weiter gesenkt

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 364259d594e9c198c10fc2d7705a32807d38d87b..0e48cd3b9bccfe24b0521682560ff47d9c6e1bb3 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -39,8 +39,8 @@ public class ApplicationConfiguration
     props.put("acks", properties.getProducerProperties().getAcks());
     props.put("batch.size", properties.getProducerProperties().getBatchSize());
     props.put("metadata.max.age.ms",  5000); //  5 Sekunden
-    props.put("delivery.timeout.ms", 20000); // 20 Sekunden
-    props.put("request.timeout.ms",  10000); // 10 Sekunden
+    props.put("delivery.timeout.ms", 10000); // 10 Sekunden
+    props.put("request.timeout.ms",   5000); //  5 Sekunden
     props.put("linger.ms", properties.getProducerProperties().getLinger().toMillis());
     props.put("compression.type", properties.getProducerProperties().getCompressionType());
     props.put("key.serializer", StringSerializer.class.getName());