]> juplo.de Git - demos/kafka/training/commit
Consumer arbeitet nicht fortlaufend: `enable.auto.commit=false` gesetzt
authorKai Moritz <kai@juplo.de>
Fri, 20 Mar 2026 14:26:21 +0000 (15:26 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 20 Mar 2026 17:41:44 +0000 (18:41 +0100)
commita8e7b475e1e1108005814ddbbef10a38896bf73f
tree3b29407d9063e64d7067e59ed660f8cabe59f49f
parent3bca0ca3521180c8bb85a7e3752c84b36757b99e
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.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java