projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: ae2e7a0) | patch
Report über gesehene Schlüssel wiederbelebt
authorKai Moritz <kai@juplo.de>
Tue, 5 Apr 2022 20:37:55 +0000 (22:37 +0200)
committerKai Moritz <kai@juplo.de>
Wed, 6 Apr 2022 17:03:56 +0000 (19:03 +0200)
commitf20231dcb36eaeee69e07192b5785bc59abc1dc1
tree6b62f52488c7d2d0207527712ff903a6198d5f89tree | snapshot
parentae2e7a02860a3ac4b26073bf0bf000a84fe894b9commit | diff
Report über gesehene Schlüssel wiederbelebt

* An der alten Stelle war die Map ja jetzt nur noch leer, da dem Consumer
  zu dem Zeitpunkt, an dem die gesehen Schlüssel ausgegeben wurden, bereits
  alle Partitionen entzogen worden sind.
* Daher werden die gesehenen Schlüssel jetzt ausgegeben, wenn eine
  Partition entzogen wird.
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.