recorder:
- image: juplo/wordcount--recorder:1.0.1
+ image: juplo/wordcount--recorder:1.2.2
labels:
- "traefik.enable=true"
- "traefik.http.routers.recorder.rule=Host(`recorder.localhost`)"
- kafka
users:
- image: juplo/wordcount--users:1.0.4
+ image: juplo/wordcount--users:1.0.7
labels:
- "traefik.enable=true"
- "traefik.http.routers.users.rule=Host(`users.localhost`)"
- kafka
splitter:
- image: juplo/wordcount--splitter:1.0.0
+ image: juplo/wordcount--splitter:1.2.2
labels:
- "traefik.enable=true"
- "traefik.http.routers.splitter.rule=Host(`splitter.localhost`)"
- kafka
counter:
- image: juplo/wordcount--counter:1.1.0
+ image: juplo/wordcount--counter:1.4.2
labels:
- "traefik.enable=true"
- "traefik.http.routers.counter.rule=Host(`counter.localhost`)"
- kafka
top10:
- image: juplo/wordcount--top10:1.0.1
+ image: juplo/wordcount--top10:1.4.2
labels:
- "traefik.enable=true"
- "traefik.http.routers.top10.rule=Host(`top10.localhost`)"
- kafka
query:
- image: juplo/wordcount--query:1.0.4
+ image: juplo/wordcount--query:2.1.2
labels:
- "traefik.enable=true"
- "traefik.http.routers.query.rule=Host(`query.localhost`)"
depends_on:
- kafka
+ popular:
+ image: juplo/wordcount--popular:1.3.2
+ labels:
+ - "traefik.enable=true"
+ - "traefik.http.routers.popular.rule=Host(`popular.localhost`)"
+ - "traefik.http.routers.popular.entrypoints=web"
+ environment:
+ juplo.wordcount.popular.bootstrap-server: kafka:9092
+ depends_on:
+ - kafka
+
bart:
- image: juplo/wordcount--fortune:1.0.0
+ image: juplo/wordcount--fortune:1.0.1
command: bash -c "
while [ true ];
do
done"
nerd:
- image: juplo/wordcount--fortune:1.0.0
+ image: juplo/wordcount--fortune:1.0.1
command: bash -c "
while [ true ];
do
done"
riddler:
- image: juplo/wordcount--fortune:1.0.0
+ image: juplo/wordcount--fortune:1.0.1
command: bash -c "
while [ true ];
do
kafka-topics --bootstrap-server kafka:9092 --describe --topic words
kafka-topics --bootstrap-server kafka:9092 --describe --topic countings
kafka-topics --bootstrap-server kafka:9092 --describe --topic top10
+ kafka-topics --bootstrap-server kafka:9092 --describe --topic popular
else
kafka-topics --bootstrap-server kafka:9092 \
--delete \
--delete \
--if-exists \
--topic top10
+ kafka-topics --bootstrap-server kafka:9092 \
+ --delete \
+ --if-exists \
+ --topic popular
kafka-topics --bootstrap-server kafka:9092 \
--create \
--topic users \
--config min.insync.replicas=1 \
&& echo Das Topic \'top10\' wurde erfolgreich angelegt: \
&& kafka-topics --bootstrap-server kafka:9092 --describe --topic top10 \
+ && kafka-topics --bootstrap-server kafka:9092 \
+ --create \
+ --topic popular \
+ --partitions 3 \
+ --replication-factor 1 \
+ --config min.insync.replicas=1 \
+ && echo Das Topic \'popular\' wurde erfolgreich angelegt: \
+ && kafka-topics --bootstrap-server kafka:9092 --describe --topic popular \
&& date > INITIALIZED
fi
stop_grace_period: 0s