`max.poll.interval.ms` und `metadata.max.age.ms` auf 5s heruntergesetzt

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 6f4e4e88091a31b6c6a325d817c856a17943c9a1..5ddfa9a59d39b45195c3d79ea7460525dd7becb6 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -35,6 +35,8 @@ public class ExampleConsumer
     props.put("client.id", clientId); // Nur zur Wiedererkennung
     props.put("key.deserializer", StringDeserializer.class.getName());
     props.put("value.deserializer", StringDeserializer.class.getName());
+    props.put("max.poll.interval.ms", 5000);
+    props.put("metadata.max.age.ms", 5000);
 
     this.id = clientId;
     this.topic = topic;