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 3284ca6674bd432ec3c02f48b5081ab7afcc1df3..0a86641a6e0d7cbc05383003d5ec62e926cb5384 100644 (file)
--- 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);