projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 60bc4a2) | patch
Wordcount-Implementierung mit Kafka-Boardmitteln und MongoDB als Storage
authorKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 19:34:43 +0000 (21:34 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:45:21 +0000 (16:45 +0200)
commita6a0a22a5fa34a01b0e8b2bc1e0e2b82d7b60f33
treefa7821d2c9d81b00c5d967c826e45eb0ad8c1bd5tree | snapshot
parent60bc4a251dc9bab71d5ab5f12870147fec253ac9commit | diff
Wordcount-Implementierung mit Kafka-Boardmitteln und MongoDB als Storage

* Zählt die Wörter pro Benutzer.
* Simple Implementierung mit Maps.
* Verwendet die bereits für das Speichern der Nachrichten-Zählung und
  der Offsets verwendete MonogoDB-Anbindung zum speichern.
* Typisierung zurückgenommn: Immer String für Key/Value
* Verwendet aus Bequemlichkeit den Seen-Endpoint von der Zählung.
docker-compose.yml diff | blob | history
pom.xml diff | blob | history
src/main/java/de/juplo/kafka/ApplicationConfiguration.java diff | blob | history
src/main/java/de/juplo/kafka/ApplicationHealthIndicator.java diff | blob | history
src/main/java/de/juplo/kafka/DriverController.java diff | blob | history
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/StatisticsDocument.java diff | blob | history
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.