]> juplo.de Git - demos/kafka/training/commit
projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: f83599b) | patch
Implementierung des Adders für SumUp
authorKai Moritz <kai@juplo.de>
Sat, 13 Aug 2022 13:15:43 +0000 (15:15 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 13:12:09 +0000 (15:12 +0200)
commit5b4b7acf7b6a02e0e5c779257d3f5996366625e6
treebabb809ae2ac3553f399186d09adfe8284075fa7tree | snapshot
parentf83599b6aaefff62c286e2143bb2e8a81751e6fdcommit | diff
Implementierung des Adders für SumUp

* `AdderRecordHandler` und `AdderRebalanceListener` implementiert, die
  die separat entwickelte Fachlogik anbinden.
* `StatisticsDocument` in `StateDocument` umbenannt und angepasst.
* Als Zustand wird zunächst nur der interne Zustand der Fachlogik
  ausgegeben.
* Später sollen statdessen die für die Benutzer durchgeführten
  Berechnungen ausgegeben werden, damit diese validiert werden können.
16 files changed:
README.sh diff | blob | history
docker-compose.yml diff | blob | history
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/AdderBusinessLogic.java diff | blob | history
src/main/java/de/juplo/kafka/AdderRebalanceListener.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/AdderRecordHandler.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationProperties.java diff | blob | history
src/main/java/de/juplo/kafka/DriverController.java diff | blob | history
src/main/java/de/juplo/kafka/PartitionStatisticsRepository.java diff | blob | history
src/main/java/de/juplo/kafka/StateDocument.java [new file with mode: 0644] blob
src/main/java/de/juplo/kafka/StatisticsDocument.java [deleted file] blob | history
src/main/java/de/juplo/kafka/WordcountRebalanceListener.java [deleted file] blob | history
src/main/java/de/juplo/kafka/WordcountRecordHandler.java [deleted file] blob | history
src/main/resources/application.yml diff | blob | history
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.