From 81f261f660f8dbe715f69baf55fe2411091fb53a Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 28 Sep 2024 11:58:11 +0200
Subject: [PATCH] `metadata.maxage.ms` auf 5 Sekunden heruntergesetzt
---
src/main/java/de/juplo/kafka/ExampleProducer.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index c3db7e7c..1b24dc70 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -30,6 +30,7 @@ public class ExampleProducer
props.put("client.id", clientId); // Nur zur Wiedererkennung
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
+ props.put("metadata.maxage.ms", 5000);
this.id = clientId;
this.topic = topic;
--
2.20.1