From: Kai Moritz Date: Tue, 22 Nov 2022 21:33:04 +0000 (+0100) Subject: Verbesserungen & Korrekturen aus simple-consumer übernommen X-Git-Tag: simple-consumer--spikzettel---lvm-2-tage--ease-path X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=309991dd1720e78bead9ea6788a1ab491fe0b625;p=demos%2Fkafka%2Ftraining Verbesserungen & Korrekturen aus simple-consumer übernommen --- diff --git a/README.sh b/README.sh index 2ea1b38..74eb764 100755 --- a/README.sh +++ b/README.sh @@ -4,17 +4,16 @@ IMAGE=juplo/simple-consumer:1.0-SNAPSHOT if [ "$1" = "cleanup" ] then - docker-compose down -v + docker-compose down -v --remove-orphans exit fi -docker-compose up -d kafka-0 kafka-1 kafka-2 kafka-3 cli +docker-compose up -d kafka-1 kafka-2 kafka-3 cli docker-compose rm -svf consumer-1 consumer-2 consumer-3 -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 producer consumer-1 consumer-2 consumer-3 +docker-compose ps sleep 5 docker-compose stop consumer-2 consumer-3 diff --git a/docker-compose.yml b/docker-compose.yml index 293db15..ce1076c 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -34,6 +34,8 @@ services: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false" ports: - 9081:9081 + depends_on: + - kafka-0 kafka-2: image: bitnami/kafka:3.3.1 @@ -58,6 +60,8 @@ services: default: aliases: - kafka + depends_on: + - kafka-0 kafka-3: image: bitnami/kafka:3.3.1 @@ -77,6 +81,9 @@ services: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false" ports: - 9083:9083 + depends_on: + - kafka-0 + setup: image: juplo/toolbox @@ -86,14 +93,22 @@ services: kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 --replication-factor 3 --config min.insync.replicas=2 kafka-topics --bootstrap-server kafka:9092 --describe --topic test " + depends_on: + - kafka-1 + - kafka-2 + - kafka-3 cli: image: juplo/toolbox command: sleep infinity + depends_on: + - kafka-1 + - kafka-2 + - kafka-3 producer: image: juplo/simple-producer:1.0-SNAPSHOT - command: producer + command: kafka:9092 test producer consumer-1: image: juplo/simple-consumer:1.0-SNAPSHOT