Upgrade clients

Signed-off-by: Tomasz Maruszak <maruszaktomasz@gmail.com>

Author: zarusz

src/Infrastructure/docker-compose.yml

@@ -3,26 +3,62 @@ version: "3.4"
 services:
   zookeeper:
     container_name: slim.zookeeper
-    image: wurstmeister/zookeeper
+    image: confluentinc/cp-zookeeper:7.8.0
     ports:
       - "2181:2181"
+    environment:
+      ZOOKEEPER_CLIENT_PORT: 2181
+      ZOOKEEPER_TICK_TIME: 2000
     networks:
       - slim
 
   kafka:
+    image: confluentinc/cp-kafka:7.8.0
     container_name: slim.kafka
-    image: wurstmeister/kafka:2.13-2.8.1
     ports:
       - "9092:9092"
     environment:
-      KAFKA_ADVERTISED_HOST_NAME: localhost
-      KAFKA_CREATE_TOPICS: "test-ping:2:1,test-echo:2:1,test-echo-resp:2:1"
+      KAFKA_BROKER_ID: 1
       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+
+      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:29092,PLAINTEXT_HOST://0.0.0.0:9092
+      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://slim.kafka:29092,PLAINTEXT_HOST://localhost:9092
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
+      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
+
+      KAFKA_AUTO_CREATE_TOPICS_ENABLE: "true"
+      KAFKA_NUM_PARTITIONS: 2
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
+      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
     depends_on:
       - zookeeper
     networks:
       - slim
 
+  kafka-init:
+    image: confluentinc/cp-kafka:7.8.0
+    container_name: slim.kafka-init
+    depends_on:
+      - kafka
+    networks:
+      - slim
+    entrypoint: ["/bin/sh", "-c"]
+    command: |
+      "
+      # Wait for Kafka to be ready
+      echo 'Waiting for Kafka to be ready...'
+      cub kafka-ready -b slim.kafka:29092 1 60
+
+      # Create topics
+      echo 'Creating topics...'
+      kafka-topics --create --if-not-exists --topic test-ping --partitions 2 --replication-factor 1 --bootstrap-server slim.kafka:29092
+      kafka-topics --create --if-not-exists --topic test-echo --partitions 2 --replication-factor 1 --bootstrap-server slim.kafka:29092
+      kafka-topics --create --if-not-exists --topic test-echo-resp --partitions 2 --replication-factor 1 --bootstrap-server slim.kafka:29092
+
+      echo 'Topics created successfully'
+      "
+
   mqtt:
     container_name: slim.mqtt
     image: eclipse-mosquitto:2.0.18
@@ -43,7 +79,7 @@ services:
     ports:
       - 5432:5432
     networks:
-      - slim      
+      - slim
 
   rabbitmq:
     container_name: slim.rabbitmq