From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Mar 2026 13:29:58 +0000 (+0100)
Subject: `max.poll.interval.ms` und `metadata.max.age.ms` auf 5s heruntergesetzt
X-Git-Tag: consumer/simple-consumer--livecoding--schritte--2026-03-22--20-47~1
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=ae4ff2f43aaa4690b4e14f9fa9510b795a689b38;p=demos%2Fkafka%2Ftraining

`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 6f4e4e88..5ddfa9a5 100644
--- 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;