From: Kai Moritz <kai@juplo.de>
Date: Fri, 20 Mar 2026 14:26:21 +0000 (+0100)
Subject: Consumer arbeitet nicht fortlaufend: `enable.auto.commit=false` gesetzt
X-Git-Tag: consumer/nodlt--2026-03-20~22
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=9f31e612eb43e9d97d237d005be814690dfe47ee;p=demos%2Fkafka%2Ftraining

Consumer arbeitet nicht fortlaufend: `enable.auto.commit=false` gesetzt

- 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.
---

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);