Update docker config

docker-compose.yaml

@@ -3,6 +3,8 @@ services:
     build:
       context: ./src
       dockerfile: banktransfer/Dockerfile
+    environment:
+      - KAFKA_CONNECT=kafka:9092 # Be careful, this is not the port 29092
   myaktion:
     build: 
       context: ./src
@@ -18,3 +20,18 @@ services:
     environment:
       - MYSQL_ROOT_PASSWORD=root
       - MYSQL_DATABASE=myaktion
+  kafka:
+    image: bitnami/kafka:3.3.2
+    container_name: kafka
+    environment:
+      - KAFKA_ENABLE_KRAFT=yes
+      - KAFKA_CFG_NODE_ID=1
+      - KAFKA_CFG_PROCESS_ROLES=broker,controller
+      - KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER
+      - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093
+      - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
+      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
+      - KAFKA_CFG_BROKER_ID=1
+      - KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=1@kafka:9093
+      - ALLOW_PLAINTEXT_LISTENER=yes
+      - KAFKA_KRAFT_CLUSTER_ID=r4zt_wrqTRuT7W2NJsB_GA

src/banktransfer/Dockerfile

@@ -13,6 +13,10 @@ RUN go generate ./...
 RUN go get
 RUN go install
 
+RUN wget https://raw.githubusercontent.com/vishnubob/wait-for-it/81b1373f17855a4dc21156cfe1694c31d7d1792e/wait-for-it.sh
+RUN chmod +x ./wait-for-it.sh ./docker-entrypoint.sh
+ENTRYPOINT ["./docker-entrypoint.sh"]
+
 CMD ["banktransfer"]
 
 EXPOSE 9111

src/banktransfer/docker-entrypoint.sh

+#!/bin/sh
+
+# Abort on any error (including if wait-for-it fails).
+set -e
+
+# Wait for kafka
+if [ -n "$KAFKA_CONNECT" ]; then
+  /go/src/app/wait-for-it.sh "$KAFKA_CONNECT" -t 120
+  # we need to wait a bit more, because sometimes kafka is not yet ready
+  sleep 1
+fi
+
+# Run the main container command.
+exec "$@"

src/myaktion/docker-entrypoint.sh

@@ -5,12 +5,12 @@ set -e
 
 # Wait for DB
 if [ -n "$DB_CONNECT" ]; then
-  /go/src/app/wait-for-it.sh "$DB_CONNECT" -t 20
+  /go/src/app/wait-for-it.sh "$DB_CONNECT" -t 120
 fi
 
 # Wait for banktransfer
 if [ -n "$BANKTRANSFER_CONNECT" ]; then
-  /go/src/app/wait-for-it.sh "$BANKTRANSFER_CONNECT" -t 20
+  /go/src/app/wait-for-it.sh "$BANKTRANSFER_CONNECT" -t 120
 fi
 
 # Run the main container command.