]> 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, 12 Jun 2026 18:50:57 +0000 (18:50 +0000)
commite46571f938108d15af0560ef4967f6596359c8c2
tree1a0e431d669dc54b8d968b353c4617b3abb38bda
parent7842a0c69e046fcf4adeaacf03fd20cd9e7247ea
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