[Spring, Kafka] IntelliJ) Spring-Kafka 초기 세팅 (Windows & WSL2)

Kafka 설치

• Kafka Binary 다운로드: https://kafka.apache.org/downloads
• 윈도우 환경 세팅 (WSL2와 포트 연결)

  netsh interface portproxy add v4tov4 listenport=9092 listenaddress=0.0.0.0 connectport=9092 connectaddress=172.X.X.X
  

  • WSL2에서 ifconfig로 IP 확인 후 connectaddress에 설정
  • https://github.com/microsoft/WSL/issues/4150
• WSL2 환경 세팅
  • 패키지 정보 업데이트

    sudo apt update
    

  • JDK 설치

    sudo apt-get install openjdk-8-jdk
    

  • PATH 세팅

    export KAFKA_HOME=/mnt/c/Users/user/downloads/kafka_2.12-2.8.0/kafka_2.12-2.8.0
    

    export PATH=$KAFKA_HOME/bin:$PATH
    

Kafka Broker 실행 옵션 설정

vi config/server.properties

• advertised.listener 부분 주석 해제 후 advertised.listeners=PLAINTEXT://172.X.X.X:9092로 변경

Kafka Zookeeper/Broker 실행

• Zookeeper 실행

  zookeeper-server-start.sh -daemon config/zookeeper.properties
  

• Broker 실행

  kafka-server-start.sh -daemon config/server.properties
  

• 실행 로그 확인

  tail -f logs/server.log
  

• JPS(Java Virtual Machine Process Status Tool)로 JVM 상 프로세스(Zookeeper, Broker) 확인

  jps -m
  

  jps -vm
  

IntelliJ에서 spring-kafka 프로젝트 생성 및 샘플 코드 실행

1. https://github.com/spring-projects/spring-kafka Fork 후 진행 또는 git clone git://github.com/spring-projects/spring-kafka.git
2. 프로젝트 빌드 (Gralde)

    cd spring-kafka
    ./gradlew build
   

   • 윈도우인 경우 gradlew build
3. Maven 프로젝트 생성
   • Edit Configurations... -> Maven 추가 -> Working Directory를 샘플 코드 폴더로 지정
   • Command line에 spring-boot:run 입력

Error

1. 2. 3.