From e76ed72c11354193eb2804a67a4527261db373bc 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 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; -- 2.20.1