projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 2900e57) | 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>
Tue, 21 Jan 2025 20:25:03 +0000 (21:25 +0100)
commit39d59a3ac1e0cb89e574c0975f51d0f6f45a31ef
treea8853a8167f30632ac51b2af69b32c620212ee85tree | snapshot
parent2900e579ca91eee1829aac10f1a84c094ab35b05commit | 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.