[BASIC #8] Kafka: Java 클라이언트 구현 환경 구축

본 프로젝트는 Spring Framework를 사용하지 않고,
순수 JAVA를 이용하여 Kafka를 사용합니다.

---

1. Intellij 프로젝트 설정 및 멀티 Module 설정

1.1. Intellij 프로젝트 시작

1.2. src build.gradle의 의존성(dependencies) 제거 후 clean build

1.3. File > New > Module 

1.4. Producers Module 추가

1.5. root의 src 제거 및 build.gradle 제거

---

2. build.gradle 의존성 설정

https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients

2.1. kafka java client 의존성

우리는 ubuntu에 Confluent Kafka 7.1.2 버전을 설치했다. Confluent Kafka 7.1.x 버전은 Apache Kafka의 3.1.x 버전과 호환되므로, Apache Kafka 3.1.x 버전을 설치한다. (본인은 3.1.0을 선택했음)

 

2.2. Slf4J API Module

https://mvnrepository.com/artifact/org.slf4j/slf4j-api/2.0.17

2.3. Slf4J Simple Provider(Binding)

https://mvnrepository.com/artifact/org.slf4j/slf4j-simple

 

---

3. UTF-8 설정

3.1. File > Settings > File Encodings

3.2. Help > Edit Custom VM Options

-Xmx4064m
-Dfile.encoding=UTF-8
-Dconsole.encoding=UTF-8

3.3. 캐시 초기화

File > Invalidate Caches

 

---

4. 모듈 만들기 (consumers)

 

[2] producers의 build.gradle을 복사해서 consumers의 build.gradle에 붙여넣기

 

[3] SimpleConsumer 클래스 생성