From: Kai Moritz Date: Sat, 28 Sep 2024 09:58:11 +0000 (+0200) Subject: `metadata.maxage.ms` auf 5 Sekunden heruntergesetzt X-Git-Tag: producer/spring-producer--fixedsharding--null~11 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=1ded72317971f6b3cbd13fa934b59a87ad5f1dea;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 a105d36..c12a75e 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;