From 6f380ff4fb895ff66fc635d8dcb15de596306d9e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=EC=A1=B0=EC=A0=95=ED=98=84=5B=EC=BB=A4=EB=A8=B8=EC=8A=A4I?=
 =?UTF-8?q?D=EA=B0=9C=EB=B0=9C=5D?= <jeong_hyun.jo@navercorp.com>
Date: Sun, 31 Dec 2023 14:09:58 +0900
Subject: [PATCH] #35 kafka setting

---
 sns_service/build.gradle.kts    |   4 +-
 sns_service/docker-compose.yaml | 105 ++++++++++++++++++++++++++++++++
 2 files changed, 108 insertions(+), 1 deletion(-)

diff --git a/sns_service/build.gradle.kts b/sns_service/build.gradle.kts
index a47a8a4..bdeaff5 100644
--- a/sns_service/build.gradle.kts
+++ b/sns_service/build.gradle.kts
@@ -33,7 +33,9 @@ dependencies {
     implementation("io.micrometer:micrometer-registry-prometheus")
     implementation ("net.logstash.logback:logstash-logback-encoder:7.3")
     implementation ("io.github.microutils:kotlin-logging:3.0.5")
-    
+    implementation("org.springframework.kafka:spring-kafka")
+
+
     compileOnly("org.projectlombok:lombok")
     annotationProcessor("org.projectlombok:lombok")
     testImplementation("org.springframework.boot:spring-boot-starter-test")
diff --git a/sns_service/docker-compose.yaml b/sns_service/docker-compose.yaml
index f68d9ca..3ca852b 100644
--- a/sns_service/docker-compose.yaml
+++ b/sns_service/docker-compose.yaml
@@ -73,6 +73,111 @@ services:
       - ./grafana/volume:/var/lib/grafana
     restart: always
 
+  zk1:
+    container_name: zookeeper1
+    image: wurstmeister/zookeeper:latest
+    restart: always
+    hostname: zk1
+    ports:
+      - "2181:2181"
+    environment:
+      ZOO_MY_ID: 1
+      ZOO_SERVERS: server.1=zk1:2888:3888;2181 server.2=zk2:2888:3888;2181 server.3=zk3:2888:3888;2181
+    volumes:
+      - "~/zk-cluster/zk1/data:/data"
+
+  zk2:
+    container_name: zookeeper2
+    image: wurstmeister/zookeeper:latest
+    restart: always
+    hostname: zk2
+    ports:
+      - "2182:2181"
+    environment:
+      ZOO_MY_ID: 2
+      ZOO_SERVERS: server.1=zk1:2888:3888;2181 server.2=zk2:2888:3888;2181 server.3=zk3:2888:3888;2181
+    volumes:
+      - "~/zk-cluster/zk2/data:/data"
+
+  zk3:
+    container_name: zookeeper3
+    image: wurstmeister/zookeeper:latest
+    restart: always
+    hostname: zk3
+    ports:
+      - "2183:2181"
+    environment:
+      ZOO_MY_ID: 3
+      ZOO_SERVERS: server.1=zk1:2888:3888;2181 server.2=zk2:2888:3888;2181 server.3=zk3:2888:3888;2181
+    volumes:
+      - "~/zk-cluster/zk3/data:/data"
+
+  kafka1:
+    container_name: kafka1
+    image: wurstmeister/kafka:latest
+    restart: on-failure
+    depends_on:
+      - zk1
+      - zk2
+      - zk3
+    ports:
+      - "9092:9092"
+    environment:
+      KAFKA_BROKER_ID: 1
+      KAFKA_ADVERTISED_HOST_NAME: host.docker.internal
+      BOOTSTRAP_SERVERS: host.docker.internal:9092, host.docker.internal:9093, host.docker.internal:9094
+      KAFKA_ZOOKEEPER_CONNECT: "zk1:2181,zk2:2182,zk3:2183"
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 2
+
+  kafka2:
+    container_name: kafka2
+    image: wurstmeister/kafka:latest
+    restart: on-failure
+    depends_on:
+      - zk1
+      - zk2
+      - zk3
+    ports:
+      - "9093:9092"
+    volumes:
+      - /var/run/docker.sock:/var/run/docker.sock
+    environment:
+      KAFKA_BROKER_ID: 2
+      KAFKA_ADVERTISED_HOST_NAME: host.docker.internal
+      BOOTSTRAP_SERVERS: host.docker.internal:9092, host.docker.internal:9093, host.docker.internal:9094
+      KAFKA_ZOOKEEPER_CONNECT: "zk1:2181,zk2:2182,zk3:2183"
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 2
+
+  kafka3:
+    container_name: kafka3
+    image: wurstmeister/kafka:latest
+    restart: on-failure
+    depends_on:
+      - zk1
+      - zk2
+      - zk3
+    ports:
+      - "9094:9092"
+    volumes:
+      - /var/run/docker.sock:/var/run/docker.sock
+    environment:
+      KAFKA_BROKER_ID: 3
+      KAFKA_ADVERTISED_HOST_NAME: host.docker.internal
+      BOOTSTRAP_SERVERS: host.docker.internal:9092, host.docker.internal:9093, host.docker.internal:9094
+      KAFKA_ZOOKEEPER_CONNECT: "zk1:2181,zk2:2182,zk3:2183"
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 2
+
+  kafka-ui:
+    image: provectuslabs/kafka-ui
+    container_name: kafka-ui
+    ports:
+      - "10000:8080"
+    restart: always
+    environment:
+      - KAFKA_CLUSTERS_0_NAME=local
+      - KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=host.docker.internal:9092,host.docker.internal:9093,host.docker.internal:9094
+      - KAFKA_CLUSTERS_0_ZOOKEEPER=zk1:2181,zk2:2182,zk1:2183
+
 volumes:
   elasticsearch-volume:
     external: false