Bereits gesehene Nachrichten werden übersprungen
authorKai Moritz <kai@juplo.de>
Fri, 26 Aug 2022 08:25:55 +0000 (10:25 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 17 Sep 2022 08:07:17 +0000 (10:07 +0200)
commit7083f2ec840ec8819a7f86b5df12da5743ea395f
tree1b70dd98e8c68d504b395d193f99c848fc08a9e2
parent25c2044064722af20f64651a32e94fb392710bbc
Bereits gesehene Nachrichten werden übersprungen

* Der `ApplicationRecordHandler` merkt sich für jede Partition den Offset
  der zuletzt erfolgreich verarbeiteten Nachrichten.
* Diese Offsets werden in der Mongo-DB mitgespeichert und daraus wieder
  hergestellt.
* Wenn der Handler eine Nachricht erhält, deren Offset nicht größer als
  der gemerkte Offset ist, wird diese mit einer Warnung verworfen.
* Vorführ-Skript so verschärft, dass deutlich wird, dass der Zustand durch
  die Verbesserung auch bei außerordentlichen Fehlern korrekt erhalten
  bleibt.
* Conflicts:
** `+src/main/java/de/juplo/kafka/ApplicationRecordHandler.java+`
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
src/main/java/de/juplo/kafka/ApplicationState.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/StateDocument.java