projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0941b5c) | patch
Fix: Fehler müssen wie bestätigte Nachrichten behandelt werden
authorKai Moritz <kai@juplo.de>
Mon, 28 Oct 2024 07:12:15 +0000 (08:12 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 29 Nov 2024 09:33:59 +0000 (10:33 +0100)
commit041dde1f232ff7d943989f38eccaf4dbc72786d0
treea6e76f6e23a4a74c737be0ad70b002dc573c62bbtree | snapshot
parent0941b5c410d8fa6471eba7c4c493200b4e2729bbcommit | diff
Fix: Fehler müssen wie bestätigte Nachrichten behandelt werden

* Ohne explizite Fehlerbehandlung müssen auch die nicht bestätigten
  Nachrichten als `acked` gezählt werden.
* Ansonsten würde die Verarbeitung in einem ``poll()``-Durchlauf mit Fehler
  hängen bleiben, da niemals alles "gesehenen" Nachrichten auch als
  "bestätigt" gezählt würden.
* Dabei: Producer-Code an den aus `producer/spring-producer` angeglichen.
src/main/java/de/juplo/kafka/ExampleConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.