X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=8b3743d89fbc196861ee9edf3144540528d5351a;hb=5c0b7b3cf822c0802c3d802a47934b6304eaed7c;hp=7a5b324e144fddbaef84c036640e62448c6f7a4f;hpb=efa942341314e29f68b895ad4c8cee766c895236;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java
index 7a5b324..8b3743d 100644
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -41,6 +41,7 @@ public class EndlessProducer implements Runnable
     props.put("bootstrap.servers", bootstrapServer);
     props.put("client.id", clientId);
     props.put("acks", acks);
+    props.put("metadata.max.age.ms", "1000");
     props.put("key.serializer", StringSerializer.class.getName());
     props.put("value.serializer", StringSerializer.class.getName());