projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 7ca1ac9) | 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, 29 Nov 2024 09:34:03 +0000 (10:34 +0100)
commit974e93f971a8e97f9d47ba1d2ea0fcd397dc4b79
treec9b862733394a706f3ec79583705a8bbb17e4f25tree | snapshot
parent7ca1ac921891a055fe649fd937fdbdf52a201a53commit | 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.