From: Kai Moritz Date: Sat, 4 Feb 2023 09:20:55 +0000 (+0100) Subject: Switched to `JsonSerializer` / `JsonDeserializer` X-Git-Tag: wordcount-2.0.0 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=c9407ccc5b4721cbeba19c8682568a99701bb98f;p=demos%2Fkafka%2Fwordcount Switched to `JsonSerializer` / `JsonDeserializer` * Switched all services from manual serialization/deserialization with direct calls to the `ObjectMapper` to ``JsonSerializer`` / ``JsonDeserializer``. * All keys and values are serialized as JSON (expect the key from `users`). --- diff --git a/README.sh b/README.sh index 4fb1760..10e475d 100755 --- a/README.sh +++ b/README.sh @@ -1,12 +1,12 @@ #!/bin/bash FORTUNE=juplo/wordcount--fortune:1.0.1 -RECORDER=juplo/wordcount--recorder:1.0.1 -USERS=juplo/wordcount--users:1.0.4 -SPLITTER=juplo/wordcount--splitter:1.0.0 -COUNTER=juplo/wordcount--counter:1.1.0 -TOP10=juplo/wordcount--top10:1.0.1 -QUERY=juplo/wordcount--query:1.0.4 +RECORDER=juplo/wordcount--recorder:1.2.0 +USERS=juplo/wordcount--users:1.0.5 +SPLITTER=juplo/wordcount--splitter:1.2.0 +COUNTER=juplo/wordcount--counter:1.3.0 +TOP10=juplo/wordcount--top10:1.2.1 +QUERY=juplo/wordcount--query:2.0.0 if [ "$1" = "cleanup" ] then @@ -89,7 +89,7 @@ http -v query.localhost/bart http -v query.localhost/nerd http -v query.localhost/riddler -// docker compose up -d --scale query=5 query +# docker compose up -d --scale query=5 query http -v --follow query.localhost/bart sleep 1 http -v --follow query.localhost/bart diff --git a/counter b/counter index fe04994..5aa0393 160000 --- a/counter +++ b/counter @@ -1 +1 @@ -Subproject commit fe049944648d9675ffe66b586b6bf860fbac696f +Subproject commit 5aa03935c0d09c363dc2b3ddcbd5fc9aac93b8e1 diff --git a/docker-compose.yml b/docker-compose.yml index 32b8a82..a466934 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -38,7 +38,7 @@ services: recorder: - image: juplo/wordcount--recorder:1.0.1 + image: juplo/wordcount--recorder:1.2.0 labels: - "traefik.enable=true" - "traefik.http.routers.recorder.rule=Host(`recorder.localhost`)" @@ -49,7 +49,7 @@ services: - kafka users: - image: juplo/wordcount--users:1.0.4 + image: juplo/wordcount--users:1.0.5 labels: - "traefik.enable=true" - "traefik.http.routers.users.rule=Host(`users.localhost`)" @@ -60,7 +60,7 @@ services: - kafka splitter: - image: juplo/wordcount--splitter:1.0.0 + image: juplo/wordcount--splitter:1.2.0 labels: - "traefik.enable=true" - "traefik.http.routers.splitter.rule=Host(`splitter.localhost`)" @@ -71,7 +71,7 @@ services: - kafka counter: - image: juplo/wordcount--counter:1.1.0 + image: juplo/wordcount--counter:1.3.0 labels: - "traefik.enable=true" - "traefik.http.routers.counter.rule=Host(`counter.localhost`)" @@ -82,7 +82,7 @@ services: - kafka top10: - image: juplo/wordcount--top10:1.0.1 + image: juplo/wordcount--top10:1.2.1 labels: - "traefik.enable=true" - "traefik.http.routers.top10.rule=Host(`top10.localhost`)" @@ -93,7 +93,7 @@ services: - kafka query: - image: juplo/wordcount--query:1.0.4 + image: juplo/wordcount--query:2.0.0 labels: - "traefik.enable=true" - "traefik.http.routers.query.rule=Host(`query.localhost`)" diff --git a/pom.xml b/pom.xml index e116624..b9ee3bc 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ de.juplo.kafka.wordcount docker pom - 1.0.2 + 2.0.0 Docker-Compose Setup Docker-Compose Setup for the multiuser-wordcount example diff --git a/query b/query index 251cf79..f929a47 160000 --- a/query +++ b/query @@ -1 +1 @@ -Subproject commit 251cf79927d4c1c941467c8fee0349c1a7eb4b93 +Subproject commit f929a47a66a2c14a291133aaa624ad9c5696bd53 diff --git a/recorder b/recorder index c5700c2..b06e664 160000 --- a/recorder +++ b/recorder @@ -1 +1 @@ -Subproject commit c5700c2117f6c445278f272572c8b5732bf53bbf +Subproject commit b06e6649f54c4ab58cea812b96301dadbbd23b23 diff --git a/splitter b/splitter index 3bc3ef7..836368a 160000 --- a/splitter +++ b/splitter @@ -1 +1 @@ -Subproject commit 3bc3ef7ceb76e7643e1e373293cfdc78f870838a +Subproject commit 836368acb5e435a733df5893e477a406daeafcb3 diff --git a/top10 b/top10 index b3c3b1c..aa9d59f 160000 --- a/top10 +++ b/top10 @@ -1 +1 @@ -Subproject commit b3c3b1c1ab19d197d323d7c69e03d9bd09147690 +Subproject commit aa9d59fa93178f40797a8bb3716dd0a30594833f diff --git a/users b/users index 58563cd..aa0d1c4 160000 --- a/users +++ b/users @@ -1 +1 @@ -Subproject commit 58563cdc022363375c00ac580672f7daa22f6453 +Subproject commit aa0d1c4c8e47b2fffc5fa0ca2cae83f64ed8dd4e