Services `schema-registry` und `connect` hinzugefĆ¼gt
[demos/kafka/training] / README.sh
1 #!/bin/bash
2
3 if [ "$1" = "cleanup" ]
4 then
5   docker-compose -f docker/docker-compose.yml down -t0 -v --remove-orphans
6   exit
7 fi
8
9 docker-compose -f docker/docker-compose.yml up -d --remove-orphans zookeeper kafka-1 kafka-2 kafka-3
10 docker-compose -f docker/docker-compose.yml ps
11 echo "Waiting for the Kafka-Cluster to become ready..."
12 docker-compose -f docker/docker-compose.yml run --rm cli cub kafka-ready -b kafka:9092 3 60 > /dev/null 2>&1 || exit 1
13
14 docker-compose -f docker/docker-compose.yml up -t0 -d cli
15 sleep 1
16 docker-compose -f docker/docker-compose.yml logs setup
17
18 echo
19 echo "Hilfe-Ausgabe von kafkacat"
20 echo
21 docker-compose -f docker/docker-compose.yml exec -T cli kafkacat -h
22 echo
23 echo "Nachrichten schreiben mit kafkacat"
24 echo
25 docker-compose -f docker/docker-compose.yml exec -T cli kafkacat -P -b kafka:9092 -t test << EOF
26 Hallo Welt!
27 Nachricht #1
28 Nachricht #2
29 Nachricht #3
30 EOF
31 echo
32 echo "Nachrichten lesen mit kafkacat"
33 echo
34 docker-compose -f docker/docker-compose.yml exec cli kafkacat -C -b kafka:9092 -t test -o beginning -e