projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: ac168b8) | patch
Fix: Nachrichten wurden ggf. doppelt verarbeitet
authorKai Moritz <kai@juplo.de>
Mon, 28 Oct 2024 10:14:31 +0000 (11:14 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 24 Jan 2025 19:19:09 +0000 (20:19 +0100)
commiteb733d41980aef7f8b0372defd518a88bcc7b6a3
tree9d05f325340cf718bca95db9dc2e97631822b6b6tree | snapshot
parentac168b8ee367e52a66c1e25a8c8144015c88a4bacommit | diff
Fix: Nachrichten wurden ggf. doppelt verarbeitet

* Wenn man in einer Schliefe die Nachrichten pro Partition separat
  verarbeitet...
* ...dann sollte man in jedem Schleifendurchlauf auch nur die Nachrichten
  der gerade zu verarbeitenden Partition abrufen!
src/main/java/de/juplo/kafka/ExampleConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.