From 9f31e612eb43e9d97d237d005be814690dfe47ee Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 20 Mar 2026 15:26:21 +0100 Subject: [PATCH] Consumer arbeitet nicht fortlaufend: `enable.auto.commit=false` gesetzt MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit - Das Speichern der Offset-Position ist nicht nötig: - Der Consumer springt gezielt einzelne Offset-Positionen an und pausiert, wenn er diese gelesen hat. - Der Consumer arbeitet mit `assign()`, als erfolgt keine durch "äußerliche" Ereignisse ausgelöste Neuzurodnung von Partitionen während der Verarbeitung. - Daher kann das Speichern der Offset-Positionen deaktiviert werden. --- 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 3284ca66..0a86641a 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -39,6 +39,7 @@ public class ApplicationConfiguration props.put("group.id", properties.getConsumerProperties().getGroupId()); props.put("key.deserializer", StringDeserializer.class.getName()); props.put("value.deserializer", StringDeserializer.class.getName()); + props.put("enable.auto.commit", false); props.put("auto.offset.reset", "none"); return new KafkaConsumer<>(props); -- 2.39.5