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