From 0d58e493e271bd397a8a0af553efae70ae4f40d3 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 22 Mar 2026 15:08:10 +0100 Subject: [PATCH] =?utf8?q?`heartbeat.interval.ms`=20und=20`session.timeout?= =?utf8?q?.ms`=20f=C3=BCr=20schnellere=20Erkennung?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 2 ++ 1 file changed, 2 insertions(+) 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; -- 2.39.5