EndlessProducer in RestProducer umgearbeitet
[demos/kafka/training] / README.sh
1 #!/bin/bash
2
3 IMAGE=juplo/rest-producer:1.0-SNAPSHOT
4
5 if [ "$1" = "cleanup" ]
6 then
7   docker-compose down -v
8   mvn clean
9   exit
10 fi
11
12 docker-compose up -d zookeeper kafka cli
13
14 if [[
15   $(docker image ls -q $IMAGE) == "" ||
16   "$1" = "build"
17 ]]
18 then
19   mvn install || exit
20 else
21   echo "Using image existing images:"
22   docker image ls $IMAGE
23 fi
24
25 echo "Waiting for the Kafka-Cluster to become ready..."
26 docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
27 docker-compose up setup
28
29 docker-compose up -d
30
31 sleep 15
32 http :8081/status
33 http :8082/status
34 http :8083/status
35 http :8084/status
36 http :8085/status
37 http :8000/seen
38
39 http post :8081/stop
40 http :8081/status
41 http :8082/status
42 http :8083/status
43 http :8084/status
44 http :8085/status
45 http :8000/seen
46
47 http post :8081/start
48
49 sleep 1
50 http :8081/status
51 http :8082/status
52 http :8083/status
53 http :8084/status
54 http :8085/status
55 http :8000/seen
56 sleep 1
57 http :8081/status
58 http :8082/status
59 http :8083/status
60 http :8084/status
61 http :8085/status
62 http :8000/seen
63 sleep 1
64 http :8081/status
65 http :8082/status
66 http :8083/status
67 http :8084/status
68 http :8085/status
69 http :8000/seen
70 sleep 1
71 http :8081/status
72 http :8082/status
73 http :8083/status
74 http :8084/status
75 http :8085/status
76 http :8000/seen
77 sleep 1
78 http :8081/status
79 http :8082/status
80 http :8083/status
81 http :8084/status
82 http :8085/status
83 http :8000/seen
84
85 http post :8081/stop
86 http :8081/status
87 http post :8082/stop
88 http :8082/status
89 http post :8083/stop
90 http :8083/status
91 http post :8084/stop
92 http :8084/status
93 http post :8085/stop
94 http :8085/status
95
96 http :8000/seen
97 http post :8000/stop
98
99 docker-compose logs producer