From 1ecada47c38bfa053e43ab755a1f8d3eff657783 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 29 Oct 2024 22:27:25 +0100 Subject: [PATCH] `delivery.timeout.ms` und `request.timeout.ms` noch weiter gesenkt --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index d251427..27209b3 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -39,8 +39,8 @@ public class ApplicationConfiguration props.put("acks", properties.getProducerProperties().getAcks()); props.put("batch.size", properties.getProducerProperties().getBatchSize()); props.put("metadata.max.age.ms", 5000); // 5 Sekunden - props.put("delivery.timeout.ms", 20000); // 20 Sekunden - props.put("request.timeout.ms", 10000); // 10 Sekunden + props.put("delivery.timeout.ms", 10000); // 10 Sekunden + props.put("request.timeout.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