From 05ec290ea491d88c9a68a886456dda3d9da1b8c3 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 8 Apr 2025 07:32:28 +0200 Subject: [PATCH] =?utf8?q?`fetch.max.wait`=20kann=20f=C3=BCr=20den=20Consu?= =?utf8?q?mer=20hier=20ausgeschaltet=20werden?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Der Consumer liest nur Nachrichten aus der Vergangenheit * Daher bremst dieser Wert das Lesen ggf. nur aus, wenn der Consumer, so wie hier in den Tests, sehr nah an der Gegenwart liest. --- 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 79a062cb..af939eac 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("key.deserializer", ByteArrayDeserializer.class.getName()); props.put("value.deserializer", ByteArrayDeserializer.class.getName()); props.put("auto.offset.reset", "none"); + props.put("fetch.max.wait.ms", 0); return new KafkaConsumer<>(props); } -- 2.39.5