From bd90c4a5a2ddb52dbcddb655b25ffc2a6db5f391 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 2 Aug 2022 19:56:17 +0200 Subject: [PATCH] =?utf8?q?Setup=20und=20README.sh=20f=C3=BCr=20rest-produc?= =?utf8?q?er=20=C3=BCberarbeitet?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Setup an das Ausgangs-Setup angeglichen. * Das Setup verwendet jetzt `kafkacat` als Consumer. * Das README.sh entsprechend der Übung und der Änderungen angepasst. --- README.sh | 35 ++++++++++++++++++++++++----- docker-compose.yml | 56 +++++++++++++++++++++++++++++++++++----------- 2 files changed, 73 insertions(+), 18 deletions(-) diff --git a/README.sh b/README.sh index 698d6dd..d2dccf8 100755 --- a/README.sh +++ b/README.sh @@ -9,7 +9,7 @@ then exit fi -docker-compose up -d zookeeper kafka cli +docker-compose up -d zookeeper kafka-1 kafka-2 kafka-3 cli if [[ $(docker image ls -q $IMAGE) == "" || @@ -27,11 +27,36 @@ docker-compose exec cli cub kafka-ready -b kafka:9092 1 60 > /dev/null 2>&1 || e docker-compose up setup docker-compose up -d -sleep 15 +while ! [[ $(http 0:8080/actuator/health 2> /dev/null) =~ "UP" ]]; do echo "Waiting for producer..."; sleep 1; done echo foo | http -v :8080/bar -dd if=/dev/zero bs=1024 count=1024 | http -v :8080/fehler -http -v :8081/seen +echo bar | http -v :8080/foo +echo foobar | http -v :8080/bar +dd if=/dev/zero bs=1024 count=1024 | http -v :8080/bar +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo +echo foofoo | http -v :8080/bar +echo barbar | http -v :8080/foo -docker-compose stop producer consumer docker-compose logs producer +docker-compose logs consumer diff --git a/docker-compose.yml b/docker-compose.yml index a16bf67..7ae8d9b 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -7,20 +7,56 @@ services: ports: - 2181:2181 - kafka: + kafka-1: image: confluentinc/cp-kafka:7.1.3 environment: KAFKA_BROKER_ID: 1 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 + KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9081 + KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-1:9092, LOCALHOST://localhost:9081 + KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER + KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT + KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 + KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" + ports: + - 9081:9081 + depends_on: + - zookeeper + + kafka-2: + image: confluentinc/cp-kafka:7.1.3 + environment: + KAFKA_BROKER_ID: 2 + KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9082 - KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka:9092, LOCALHOST://localhost:9082 + KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-2:9092, LOCALHOST://localhost:9082 KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 + KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" ports: - 9092:9082 - 9082:9082 + networks: + default: + aliases: + - kafka + depends_on: + - zookeeper + + kafka-3: + image: confluentinc/cp-kafka:7.1.3 + environment: + KAFKA_BROKER_ID: 3 + KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 + KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9083 + KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka-3:9092, LOCALHOST://localhost:9083 + KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER + KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT + KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 + KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" + ports: + - 9083:9083 depends_on: - zookeeper @@ -29,7 +65,8 @@ services: command: > bash -c " kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic test - kafka-topics --bootstrap-server kafka:9092 --create --topic test --partitions 2 + 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 " cli: @@ -47,12 +84,5 @@ services: producer.topic: test consumer: - image: juplo/endless-consumer:1.0-SNAPSHOT - ports: - - 8081:8080 - environment: - server.port: 8080 - consumer.bootstrap-server: kafka:9092 - consumer.client-id: my-group - consumer.client-id: consumer - consumer.topic: test + image: juplo/toolbox + command: kafkacat -C -b kafka:9092 -t test -o 0 -f'p=%p|o=%o|k=%k|v=%s\n' -- 2.20.1