projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 50063aa) | 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>
Sun, 10 Nov 2024 13:27:08 +0000 (14:27 +0100)
commit887a199de82dad5f0c7e4f7126608edc28b6336f
tree01bee643feb1e404b5bd7af3978d3a8ff615d823tree | snapshot
parent50063aa1ee2a99b7f7638fb6c50885bb3f7f2fc6commit | 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.