projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: a093e8b) | 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>
Thu, 6 Feb 2025 16:55:40 +0000 (17:55 +0100)
commit85415eb2a15dfa820db621a9e1cd068c3fc5c711
tree2a6df24b6216c321e85614b4cdf9a7af319f797dtree | snapshot
parenta093e8b0a2828c1772961be5c661b701642156afcommit | 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.