projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 3b2b136) | 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>
Tue, 21 Jan 2025 20:25:03 +0000 (21:25 +0100)
commit018e77e33c0de12a2845f8038f9faf661f9dbe5f
treeded11df4d786c1dc407325ea3133e541ac8dacfdtree | snapshot
parent3b2b136e0c5d53857611e72e381493c362c9e25bcommit | 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.