From ae4ff2f43aaa4690b4e14f9fa9510b795a689b38 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Mar 2026 14:29:58 +0100
Subject: [PATCH] `max.poll.interval.ms` und `metadata.max.age.ms` auf 5s
 heruntergesetzt

---
 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 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;
-- 
2.39.5