From 323cef850b8c5ae4b9b697a93fd7b6ea926febe1 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 29 Oct 2024 22:38:39 +0100 Subject: [PATCH] `max.block.ms` auf 5s gesetzt MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Sonst entsteht bei verschiedenen Fehlern schnell ein falscher Eindruck * Man könnte sonst auf die Idee kommen, dass der Producer für diese beliebig lange wartet! --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 27209b3..2b69696 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -41,6 +41,7 @@ public class ApplicationConfiguration props.put("metadata.max.age.ms", 5000); // 5 Sekunden props.put("delivery.timeout.ms", 10000); // 10 Sekunden props.put("request.timeout.ms", 5000); // 5 Sekunden + props.put("max.block.ms", 5000); // 5 Sekunden props.put("linger.ms", properties.getProducerProperties().getLinger().toMillis()); props.put("compression.type", properties.getProducerProperties().getCompressionType()); props.put("key.serializer", StringSerializer.class.getName()); -- 2.20.1