echo "Waiting for the Kafka-Cluster to become ready..."
docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || exit 1
docker-compose up setup
-
docker-compose up -d
sleep 15
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-
-http post :8081/stop
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-
-http post :8081/start
-
-sleep 1
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-sleep 1
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-sleep 1
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-sleep 1
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-sleep 1
-http :8081/status
-http :8082/status
-http :8083/status
-http :8084/status
-http :8085/status
-http :8000/seen
-
-http post :8081/stop
-http :8081/status
-http post :8082/stop
-http :8082/status
-http post :8083/stop
-http :8083/status
-http post :8084/stop
-http :8084/status
-http post :8085/stop
-http :8085/status
-http :8000/seen
-http post :8000/stop
+echo foo | http :8080/bar
+dd if=/dev/zero bs=1024 count=1024 | http :8080/fehler
+http :8081/seen
+docker-compose stop producer consumer
docker-compose logs producer
producer.client-id: producer
producer.topic: test
- peter:
- image: juplo/rest-client:1.0-SNAPSHOT
- ports:
- - 8081:8080
- environment:
- server.port: 8080
- rest-client.baseUrl: http://producer:8080
- rest-client.username: peter
- rest-client.throttle-ms: 1000
-
- klaus:
- image: juplo/rest-client:1.0-SNAPSHOT
- ports:
- - 8082:8080
- environment:
- server.port: 8080
- rest-client.baseUrl: http://producer:8080
- rest-client.username: klaus
- rest-client.throttle-ms: 1100
-
- beate:
- image: juplo/rest-client:1.0-SNAPSHOT
- ports:
- - 8083:8080
- environment:
- server.port: 8080
- rest-client.baseUrl: http://producer:8080
- rest-client.username: beate
- rest-client.throttle-ms: 900
-
- franz:
- image: juplo/rest-client:1.0-SNAPSHOT
- ports:
- - 8084:8080
- environment:
- server.port: 8080
- rest-client.baseUrl: http://producer:8080
- rest-client.username: franz
- rest-client.throttle-ms: 800
-
- uschi:
- image: juplo/rest-client:1.0-SNAPSHOT
- ports:
- - 8085:8080
- environment:
- server.port: 8080
- rest-client.baseUrl: http://producer:8080
- rest-client.username: uschi
- rest-client.throttle-ms: 1200
-
consumer:
image: juplo/counting-consumer:1.0-SNAPSHOT
ports:
- - 8000:8081
+ - 8081:8081
environment:
consumer.bootstrap-server: kafka:9092
consumer.client-id: my-group