]> 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>
Sun, 31 May 2026 12:52:20 +0000 (12:52 +0000)
commit288cfbb69de135dc2610879c6308f3c9f15bb463
tree2e8fc9604fd5b0cba2f2b39eea5160d5f74517af
parent581fc8e15a5c9d37ca3b7b1b62a7d08adb0da1d2
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