From 33f997af92d23c173e9146480e8c9e72db46ee5e Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
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 27209b3b..2b69696d 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