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 5822014b6f9bbed56b3583278eb7f8f79057b0de..8111e0e4548a5822b00d4e0f0b585f4ad7c4c0a8 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -38,6 +38,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);