4 image: confluentinc/cp-zookeeper:6.2.0
6 ZOOKEEPER_CLIENT_PORT: 2181
11 image: confluentinc/cp-kafka:6.2.0
14 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
15 KAFKA_LISTENERS: DOCKER://:9092, LOCALHOST://:9082
16 KAFKA_ADVERTISED_LISTENERS: DOCKER://kafka:9092, LOCALHOST://localhost:9082
17 KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER
18 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT
19 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
20 KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
21 KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
22 KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
33 #- "--log.level=DEBUG"
34 - "--api.insecure=true"
35 - "--providers.docker=true"
36 - "--providers.docker.exposedbydefault=false"
37 - "--entrypoints.web.address=:80"
42 - "/var/run/docker.sock:/var/run/docker.sock:ro"
45 image: juplo/wordcount--recorder:1.0.1
47 - "traefik.enable=true"
48 - "traefik.http.routers.recorder.rule=Host(`recorder.localhost`)"
49 - "traefik.http.routers.recorder.entrypoints=web"
51 juplo.wordcount.recorder.bootstrap-server: kafka:9092
56 image: juplo/wordcount--users:1.0.4
58 - "traefik.enable=true"
59 - "traefik.http.routers.users.rule=Host(`users.localhost`)"
60 - "traefik.http.routers.users.entrypoints=web"
62 juplo.wordcount.users.bootstrap-server: kafka:9092
67 image: juplo/wordcount--splitter:1.0.0-spring-integration
69 - "traefik.enable=true"
70 - "traefik.http.routers.splitter.rule=Host(`splitter.localhost`)"
71 - "traefik.http.routers.splitter.entrypoints=web"
73 spring.kafka.bootstrap-servers: kafka:9092
78 image: juplo/wordcount--counter:1.1.0
80 - "traefik.enable=true"
81 - "traefik.http.routers.counter.rule=Host(`counter.localhost`)"
82 - "traefik.http.routers.counter.entrypoints=web"
84 juplo.wordcount.counter.bootstrap-server: kafka:9092
89 image: juplo/wordcount--top10:1.0.1
91 - "traefik.enable=true"
92 - "traefik.http.routers.top10.rule=Host(`top10.localhost`)"
93 - "traefik.http.routers.top10.entrypoints=web"
95 juplo.wordcount.top10.bootstrap-server: kafka:9092
100 image: juplo/wordcount--query:1.0.4
102 - "traefik.enable=true"
103 - "traefik.http.routers.query.rule=Host(`query.localhost`)"
104 - "traefik.http.routers.query.entrypoints=web"
106 juplo.wordcount.query.bootstrap-server: kafka:9092
111 image: juplo/wordcount--fortune:1.0.0
115 /usr/games/fortune chalkboard
117 | http -v recorder:8081/bart;
123 image: juplo/wordcount--fortune:1.0.0
127 /usr/games/fortune computers
128 | grep -v '^[[:space:]]*--'
129 | http -v recorder:8081/nerd;
135 image: juplo/wordcount--fortune:1.0.0
139 /usr/games/fortune riddles
140 | awk -F':' '/^Q/ { print $$2 }'
141 | http -v recorder:8081/riddler;
149 cub kafka-ready -b kafka:9092 1 60 ;
150 kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic recordings ;
151 kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic users ;
152 kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic words ;
153 kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic countings ;
154 kafka-topics --bootstrap-server kafka:9092 --create --partitions 10 --if-not-exists --topic top10 ;
158 image: tchiotludo/akhq:0.18.0
160 - "traefik.enable=true"
161 - "traefik.http.routers.akhq.rule=Host(`akhq.localhost`)"
162 - "traefik.http.routers.akhq.entrypoints=web"
166 AKHQ_CONFIGURATION: |
171 bootstrap.servers: "kafka:9092"