From 1ded72317971f6b3cbd13fa934b59a87ad5f1dea Mon Sep 17 00:00:00 2001 From: Kai Moritz 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 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; -- 2.20.1