From 69197990ecea4d0db7927174a4412ab4d82f86b9 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 06e14ef..a629c64 100644 --- a/src/main/java/de/juplo/kafka/ExampleProducer.java +++ b/src/main/java/de/juplo/kafka/ExampleProducer.java @@ -27,6 +27,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