From f958eaf806d745d3ef7f639f667b12b79eed433d Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 16 May 2025 07:33:11 +0200 Subject: [PATCH] =?utf8?q?Tuning-Parameter=20f=C3=BCr=20Fehlerbehandlung?= =?utf8?q?=20mit=20Defaults=20vorbelegt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ExampleProducer.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java index 0bab442..8daf0aa 100644 --- a/src/main/java/de/juplo/kafka/ExampleProducer.java +++ b/src/main/java/de/juplo/kafka/ExampleProducer.java @@ -30,6 +30,9 @@ 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("delivery.timeout.ms", 2147483647); + props.put("buffer.memory", 32768); + props.put("max.block.ms", 5000); this.id = clientId; this.topic = topic; -- 2.20.1