X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=ba2566ee42b1d8d9fcd41150bb3125f7129697d6;hb=40c2e597c8b695fe3d5e2675ce0c1a975b0065bd;hp=c7f4e19d95f5c36e74b0eb62041cd5ef247136e5;hpb=ea7667e25a8759e168e1d31ecd8d42834c646b8b;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index c7f4e19..ba2566e 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -1,78 +1,187 @@ version: '3.2' services: zookeeper: - image: confluentinc/cp-zookeeper:7.0.2 + image: confluentinc/cp-zookeeper:7.1.3 environment: ZOOKEEPER_CLIENT_PORT: 2181 ports: - 2181:2181 - kafka: - image: confluentinc/cp-kafka:7.0.2 + 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 mongo: - image: mongo:4.4 + image: mongo:4.4.13 ports: - 27017:27017 environment: MONGO_INITDB_ROOT_USERNAME: juplo MONGO_INITDB_ROOT_PASSWORD: training + express: + image: mongo-express + ports: + - 8090:8081 + environment: + ME_CONFIG_MONGODB_ADMINUSERNAME: juplo + ME_CONFIG_MONGODB_ADMINPASSWORD: training + ME_CONFIG_MONGODB_URL: mongodb://juplo:training@mongo:27017/ + depends_on: + - mongo + setup: image: juplo/toolbox 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 --delete --if-exists --topic in + kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic out + kafka-topics --bootstrap-server kafka:9092 --create --topic in --partitions 2 --replication-factor 3 --config min.insync.replicas=2 + kafka-topics --bootstrap-server kafka:9092 --create --topic out --partitions 2 --replication-factor 3 --config min.insync.replicas=2 + kafka-topics --bootstrap-server kafka:9092 --describe --topic in + kafka-topics --bootstrap-server kafka:9092 --describe --topic out " cli: image: juplo/toolbox command: sleep infinity - producer: - image: juplo/endless-producer:1.0-SNAPSHOT + gateway: + image: juplo/sumup-gateway:1.0-SNAPSHOT ports: - - 8000:8080 + - 8080:8080 environment: - producer.bootstrap-server: kafka:9092 - producer.client-id: producer - producer.topic: test - producer.throttle-ms: 500 - + server.port: 8080 + sumup.gateway.bootstrap-server: kafka:9092 + sumup.gateway.client-id: gateway + sumup.gateway.topic: in - peter: - image: juplo/endless-consumer:1.0-SNAPSHOT + requests: + image: juplo/sumup-requests:1.0-SNAPSHOT ports: - - 8081:8081 + - 8081:8080 environment: - consumer.bootstrap-server: kafka:9092 - consumer.client-id: peter - consumer.topic: test - spring.data.mongodb.uri: mongodb://juplo:training@mongo:27017 - spring.data.mongodb.database: juplo + server.port: 8080 + sumup.requests.bootstrap-server: kafka:9092 + sumup.requests.client-id: requests - beate: - image: juplo/endless-consumer:1.0-SNAPSHOT + adder: + image: juplo/sumup-adder:1.0-SNAPSHOT ports: - - 8082:8081 + - 8082:8080 environment: - consumer.bootstrap-server: kafka:9092 - consumer.client-id: beate - consumer.topic: test + server.port: 8080 + sumup.adder.bootstrap-server: kafka:9092 + sumup.adder.client-id: adder spring.data.mongodb.uri: mongodb://juplo:training@mongo:27017 spring.data.mongodb.database: juplo + + peter: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/peter; + sleep 1; + done + " + ute: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/ute; + sleep 2; + done + " + franz: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/franz; + sleep 3; + done + " + beate: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/beate; + sleep 4; + done + " + klaus: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/klaus; + sleep 5; + done + " + uschi: + image: juplo/toolbox + command: > + bash -c " + while [[ true ]]; + do + echo 666 | http -v gateway:8080/uschi; + sleep 6; + done + "