From: Kai Moritz Date: Sat, 28 Sep 2024 09:58:11 +0000 (+0200) Subject: `metadata.maxage.ms` auf 5 Sekunden heruntergesetzt X-Git-Tag: grundlagen/simple-producer--vorlage--2024-11-13--si~2 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=e76ed72c11354193eb2804a67a4527261db373bc;p=demos%2Fkafka%2Ftraining `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 72fa2dc..aa014a6 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;