projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5ac4e6f) | 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, 29 Nov 2024 09:34:03 +0000 (10:34 +0100)
commit6e53dc14e2f19d055a0f0d54f239c35e44a94581
tree09e0eb7fd7e580094daa78ad3f44f32c9d055f93tree | snapshot
parent5ac4e6f8ce7636111545a435cc66c126080f903dcommit | 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.