version: '3.2' services: zookeeper: image: confluentinc/cp-zookeeper:7.1.3 environment: ZOOKEEPER_CLIENT_PORT: 2181 ports: - 2181:2181 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-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: 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.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 in kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic out kafka-topics --bootstrap-server kafka:9092 --delete --if-exists --topic out.DLT 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 --create --topic out.DLT --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 kafka-topics --bootstrap-server kafka:9092 --describe --topic out.DLT " cli: image: juplo/toolbox command: sleep infinity gateway: image: juplo/sumup-gateway--springified:1.0-SNAPSHOT ports: - 8080:8080 environment: server.port: 8080 spring.kafka.bootstrap-servers: kafka:9092 spring.kafka.client-id: gateway sumup.gateway.topic: in requests-1: image: juplo/sumup-requests-json:1.0-SNAPSHOT ports: - 8081:8080 environment: server.port: 8080 sumup.requests.bootstrap-server: kafka:9092 sumup.requests.client-id: requests-1 requests-2: image: juplo/sumup-requests-json:1.0-SNAPSHOT ports: - 8082:8080 environment: server.port: 8080 sumup.requests.bootstrap-server: kafka:9092 sumup.requests.client-id: requests-2 adder-1: image: juplo/sumup-adder-springified:1.0-SNAPSHOT ports: - 8091:8080 environment: server.port: 8080 spring.kafka.bootstrap-servers: kafka:9092 spring.kafka.producer.bootstrap-servers: kafka:9092 spring.kafak.client-id: adder-1 spring.kafka.auto-commit-interval: 1s sumup.adder.throttle: 3ms spring.data.mongodb.uri: mongodb://juplo:training@mongo:27017 spring.data.mongodb.database: juplo logging.level.org.apache.kafka.clients.consumer: DEBUG adder-2: image: juplo/sumup-adder-springified:1.0-SNAPSHOT ports: - 8092:8080 environment: server.port: 8080 spring.kafka.bootstrap-servers: kafka:9092 spring.kafka.producer.bootstrap-servers: kafka:9092 spring.kafak.client-id: adder-2 spring.kafka.auto-commit-interval: 1s sumup.adder.throttle: 3ms spring.data.mongodb.uri: mongodb://juplo:training@mongo:27017 spring.data.mongodb.database: juplo logging.level.org.apache.kafka.clients.consumer: DEBUG peter: image: juplo/toolbox command: > bash -c " while [[ true ]]; do echo 666 | http -v gateway:8080/peter; sleep 1; done " klaus: image: juplo/toolbox command: > bash -c " while [[ true ]]; do echo 666 | http -v gateway:8080/klaus; sleep 1; done " dlt: image: juplo/toolbox tty: true command: kafkacat -C -b kafka:9092 -t out.DLT -f'p=%p|o=%o|%k=%s\n' -o 0 -q