projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: e2e7ed4) | patch
GET-Endpoint zum Abfragen der Schlüssel-Zählungen ergänzt
authorKai Moritz <kai@juplo.de>
Sun, 27 Oct 2024 12:38:47 +0000 (13:38 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 8 Nov 2024 17:21:16 +0000 (18:21 +0100)
commit9339a4c3cf18023135a6a89b5c09446f59b59fe3
treeeb9493144e2a946427d0be05c96c5b18540eb678tree | snapshot
parente2e7ed4987ac9fcabb313a948f022e98e9c9e0a7commit | diff
GET-Endpoint zum Abfragen der Schlüssel-Zählungen ergänzt

* Zugriff auf die `counterMap` in `ExampleConsumer` synchronisiert.
* `CounterStateController` kopiert die Map, um mögliche konkurierende
  Zugriffe während des Erzeugens der Ausgabe zu vermeiden.
src/main/java/de/juplo/kafka/CounterStateController.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/ExampleConsumer.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.