projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: c6d1ded) | 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>
Sun, 10 Nov 2024 13:26:07 +0000 (14:26 +0100)
commitdbf535d03227e245497b31da3a9a4da650902787
tree833136bf6ef3f3fce09d53aca736a3d1635ca7ddtree | snapshot
parentc6d1ded087826ef257b54c69fb7c654b21d55a81commit | 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.