`heartbeat.interval.ms` und `session.timeout.ms` für schnellere Erkennung

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 5ddfa9a59d39b45195c3d79ea7460525dd7becb6..02d4e9e1c4a673209def73d9bb3c183114ba7c52 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -37,6 +37,8 @@ public class ExampleConsumer
     props.put("value.deserializer", StringDeserializer.class.getName());
     props.put("max.poll.interval.ms", 5000);
     props.put("metadata.max.age.ms", 5000);
+    props.put("heartbeat.interval.ms", 1000);
+    props.put("session.timeout.ms", 10000);
 
     this.id = clientId;
     this.topic = topic;