]> 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 14:26:21 +0000 (15:26 +0100)
commit9f31e612eb43e9d97d237d005be814690dfe47ee
treecc90524293dd0aa2241238d25ae1f0aa8f533a54
parent6bd97866a704283352f41abd2352a7cdc1da7343
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