projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Compose-Setup für erste Übung _ohne_ Fehlerteufel!
[demos/kafka/training]
/
README.sh
diff --git
a/README.sh
b/README.sh
index
c9494b9
..
e990bf2
100755
(executable)
--- a/
README.sh
+++ b/
README.sh
@@
-1,6
+1,6
@@
#!/bin/bash
#!/bin/bash
-IMAGE=juplo/sumup-adder:1.0-SNAPSHOT
+IMAGE=juplo/sumup-adder
-json
:1.0-SNAPSHOT
if [ "$1" = "cleanup" ]
then
if [ "$1" = "cleanup" ]
then
@@
-34,44
+34,32
@@
while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Wait
while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for requests-1..."; sleep 1; done
while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for requests-2..."; sleep 1; done
while ! [[ $(http 0:8081/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for requests-1..."; sleep 1; done
while ! [[ $(http 0:8082/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for requests-2..."; sleep 1; done
-docker-compose up -d
peter klaus
+docker-compose up -d
adder-1 adder-2
-docker-compose up -d adder-1
while ! [[ $(http 0:8091/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder-1..."; sleep 1; done
while ! [[ $(http 0:8091/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder-1..."; sleep 1; done
-while [[ "$(http :8091/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up on adder-1..."; sleep 1; done
-http -v --pretty none -S :8091/results
-echo
-
-sleep 3
-echo "Resultate für adder-1"
-http -v --pretty none -S :8091/results
-echo
+while ! [[ $(http 0:8092/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder-2..."; sleep 1; done
-echo "Resultate für peter von adder-1"
-http :8091/results/peter | jq .[].sum | uniq
-echo
"Resultate für klaus von adder-1"
-http :8091/results/klaus | jq .[].sum | uniq
+# tag::nachrichten[]
+echo 5 | http -v :8080/peter
+echo
5 | http -v :8080/klaus
+# end::nachrichten[]
+while [[ "$(http :8091/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up on adder-1..."; sleep 1; done
+echo "Resultate für adder-1"
+# tag::resultate[]
+http -v :8091/results
+# end::resultate[]
-docker-compose up -d adder-2
-while ! [[ $(http 0:8092/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for adder-2..."; sleep 1; done
while [[ "$(http :8092/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up on adder-2..."; sleep 1; done
while [[ "$(http :8092/results | jq -r .)" == "{}" ]]; do echo "Waiting for some results to show up on adder-2..."; sleep 1; done
-http -v --pretty none -S :8092/results
-echo
-
-sleep 3
echo "Resultate für adder-2"
echo "Resultate für adder-2"
-http -v --pretty none -S :8092/results
-echo
-
-echo "Resultate für peter von adder-1"
-http :8091/results/peter | jq .[].sum | uniq
-echo "Resultate für klaus von adder-1"
-http :8091/results/klaus | jq .[].sum | uniq
+# tag::resultate[]
+http -v :8092/results
+# end::resultate[]
-echo "
Resultate für peter von adder-2
"
-http :8092/results/peter | jq .[].sum | uniq
-echo
"Resultate für klaus von adder-2"
-http :8092/results/klaus | jq .[].sum | uniq
+echo "
Writing poison pill into topic out...
"
+# tag::poisonpill[]
+echo
'BOOM!' | kafkacat -P -b :9092 -t out
+# end::poisonpill[]
-docker-compose kill -s 9 peter klaus
+sleep 5
+docker-compose ps adder-1 adder-2