`metadata.maxage.ms` auf 5 Sekunden heruntergesetzt

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 06e14efe4f14d9a43d55375aa9676cd0b53f08aa..a629c64b8ddc2ce5155622aaf89dd1e126922e8d 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -27,6 +27,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;