From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Mar 2026 14:08:10 +0000 (+0100)
Subject: `heartbeat.interval.ms` und `session.timeout.ms` für schnellere Erkennung
X-Git-Tag: consumer/simple-consumer--livecoding--schritte--2026-03-22--22-01
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=0d58e493e271bd397a8a0af553efae70ae4f40d3;p=demos%2Fkafka%2Ftraining

`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 5ddfa9a5..02d4e9e1 100644
--- 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;