path = fortune
url = ./
branch = fortune
+[submodule "splitter"]
+ path = splitter
+ url = ./
#!/bin/bash
FORTUNE=juplo/wordcount--fortune:1.0.0
-RECORDER=juplo/wordcount--recorder:1.0.1
+RECORDER=juplo/wordcount--recorder:1.1.0
USERS=juplo/wordcount--users:1.0.4
-COUNTER=juplo/wordcount--counter:1.0.1
+SPLITTER=juplo/wordcount--splitter:1.1.4
+COUNTER=juplo/wordcount--counter:1.2.4
TOP10=juplo/wordcount--top10:1.0.1
QUERY=juplo/wordcount--query:1.0.4
docker image rm $FORTUNE
docker image rm $RECORDER
docker image rm $USERS
+ docker image rm $SPLITTER
docker image rm $COUNTER
docker image rm $TOP10
docker image rm $QUERY
$(docker image ls -q $FORTUNE) == "" ||
$(docker image ls -q $RECORDER) == "" ||
$(docker image ls -q $USERS) == "" ||
+ $(docker image ls -q $SPLITTER) == "" ||
$(docker image ls -q $COUNTER) == "" ||
$(docker image ls -q $TOP10) == "" ||
$(docker image ls -q $QUERY) == "" ||
]]
then
mvn clean package || exit
- docker-compose rm -svf recorder users counter top10 query
+ docker-compose rm -svf recorder users splitter counter top10 query
( cd fortune; ./README.sh $FORTUNE; )
mvn -f recorder/pom.xml docker:build
mvn -f users/pom.xml docker:build
+ mvn -f splitter/pom.xml docker:build
mvn -f counter/pom.xml docker:build
mvn -f top10/pom.xml docker:build
mvn -f query/pom.xml docker:build
docker image ls $FORTUNE
docker image ls $RECORDER
docker image ls $USERS
+ docker image ls $SPLITTER
docker image ls $COUNTER
docker image ls $TOP10
docker image ls $QUERY
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
-Subproject commit b1623c2b645c614424ceec3bc71008c900d82115
+Subproject commit dd4d5ddb60f7ca495d65d49f93eb4c07e0d03e22
- "/var/run/docker.sock:/var/run/docker.sock:ro"
recorder:
- image: juplo/wordcount--recorder:1.0.1
+ image: juplo/wordcount--recorder:1.1.0
labels:
- "traefik.enable=true"
- "traefik.http.routers.recorder.rule=Host(`recorder.localhost`)"
depends_on:
- kafka
+ splitter:
+ image: juplo/wordcount--splitter:1.1.4
+ labels:
+ - "traefik.enable=true"
+ - "traefik.http.routers.splitter.rule=Host(`splitter.localhost`)"
+ - "traefik.http.routers.splitter.entrypoints=web"
+ environment:
+ juplo.wordcount.splitter.bootstrap-server: kafka:9092
+ depends_on:
+ - kafka
+
counter:
- image: juplo/wordcount--counter:1.0.1
+ image: juplo/wordcount--counter:1.2.4
labels:
- "traefik.enable=true"
- "traefik.http.routers.counter.rule=Host(`counter.localhost`)"
image: juplo/toolbox
command: bash -c "
cub kafka-ready -b kafka:9092 1 60 ;
- kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --topic recordings ;
- kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --topic users ;
- kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --topic countings ;
- kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --topic top10 ;
+ kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic recordings ;
+ kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic users ;
+ kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic words ;
+ kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic countings ;
+ kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic top10 ;
sleep infinity"
akhq:
docker-kafka-server:
properties:
bootstrap.servers: "kafka:9092"
-
-networks:
- default:
- external:
- name: trion
-Subproject commit 5dd5c422829ceac252d5c13d0022acff40f76185
+Subproject commit dde18ef24d54bb988ad458ad6e12ed99fbc53061
<groupId>de.juplo.kafka.wordcount</groupId>
<artifactId>docker</artifactId>
<packaging>pom</packaging>
- <version>1.0.1</version>
+ <version>1.0.2</version>
<name>Docker-Compose Setup</name>
<description>Docker-Compose Setup for the multiuser-wordcount example</description>
<modules>
<module>recorder</module>
<module>users</module>
+ <module>splitter</module>
<module>counter</module>
<module>top10</module>
<module>query</module>
-Subproject commit c5700c2117f6c445278f272572c8b5732bf53bbf
+Subproject commit 22615ba45bd7697e041eb10f88166cd2074de305
--- /dev/null
+Subproject commit 2b48657cac59447a359a9ce52c250bf25a559cbc
-Subproject commit 097a537e42272d105354a708e5138abf5488b28a
+Subproject commit 58563cdc022363375c00ac580672f7daa22f6453