]> 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.milan.moritz@googlemail.com>
Fri, 29 May 2026 20:32:24 +0000 (20:32 +0000)
commit95020a804707891c702e58650cdfe16653c54099
treee7cd84f5a012048ddf5bbe4e4073aefd807c62ea
parenteb62d074a8b6d656b3674e417452f633c42b6a59
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