projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5abcc2a) | patch
Der Zählerzustand wird separat pro Partition verwaltet
authorKai Moritz <kai@juplo.de>
Sat, 2 Nov 2024 15:54:01 +0000 (16:54 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 8 Nov 2024 17:21:16 +0000 (18:21 +0100)
commit998470eaf40bb71f517423e1aee8726aaf258d84
treee2384e30a1603eed8f2d04d934bb83744921b7fetree | snapshot
parent5abcc2a99e3e6ff04ce9afcc6f402592f2990b3ccommit | diff
Der Zählerzustand wird separat pro Partition verwaltet

* Dadurch ist es möglich, den Zustand für entzogene Partitionen zu löschen.
* D.h., bei der Ausgabe ist immer klar ersichtlich, über welchen Zustand
  die angefragte Instanz gerade verfügt.
src/main/java/de/juplo/kafka/CounterStateController.java diff | blob | history
src/main/java/de/juplo/kafka/ExampleConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.