`max.block.ms` auf 5s gesetzt

* Sonst entsteht bei verschiedenen Fehlern schnell ein falscher Eindruck
* Man könnte sonst auf die Idee kommen, dass der Producer für diese
  beliebig lange wartet!

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 27209b3b8ae278d3f794797957d5c2c8f8b85a3f..2b69696d5e1b3c3145b4dd5542335d3b1285d118 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -41,6 +41,7 @@ public class ApplicationConfiguration
     props.put("metadata.max.age.ms",  5000); //  5 Sekunden
     props.put("delivery.timeout.ms", 10000); // 10 Sekunden
     props.put("request.timeout.ms",   5000); //  5 Sekunden
+    props.put("max.block.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());