projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 7cf65b5) | patch
Refaktorisierung für Tests - Record-Handler als Bean konfigurierbar
authorKai Moritz <kai@juplo.de>
Sat, 9 Apr 2022 11:40:47 +0000 (13:40 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 11 Apr 2022 13:07:20 +0000 (15:07 +0200)
commit9259b912d4294b7b21b49536ed1cc72175e1b2eb
tree609f68591258cf3ef32519d168cd1e7fcebbd42ftree | snapshot
parent7cf65b5089d103542849e4ca12b6f6df6ad79aa0commit | diff
Refaktorisierung für Tests - Record-Handler als Bean konfigurierbar

* Ein Handler für die Verarbeitung der einzelnen ConsumerRecord's kann
  jetzt ein `java.util.function.Consumer` als Bean definiert werden
* Die Nachricht wird erst nach dem Aufruf des Handlers als konsumiert
  gezählt, damit der Handler die Nachricht über eine Exception ablehnen
  kann.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.