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
treebabb809ae2ac3553f399186d09adfe8284075fa7
parentf83599b6aaefff62c286e2143bb2e8a81751e6fd
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
docker-compose.yml
pom.xml
src/main/java/de/juplo/kafka/AdderBusinessLogic.java
src/main/java/de/juplo/kafka/AdderRebalanceListener.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/AdderRecordHandler.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationProperties.java
src/main/java/de/juplo/kafka/DriverController.java
src/main/java/de/juplo/kafka/PartitionStatisticsRepository.java
src/main/java/de/juplo/kafka/StateDocument.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/StatisticsDocument.java [deleted file]
src/main/java/de/juplo/kafka/WordcountRebalanceListener.java [deleted file]
src/main/java/de/juplo/kafka/WordcountRecordHandler.java [deleted file]
src/main/resources/application.yml
src/test/java/de/juplo/kafka/ApplicationTests.java