Kafka - WSL2 설치 및 실행

3.1.0 version 기준 설치 example

# jdk 설치
sudo apt install openjdk-11jdk
java -version
javac -version

#kafka 링크 이용하여 다운로드
wget https://archive.apache.org/dist/kafka/3.1.0/kafka_2.13-3.1.0.tgz

# kafka bin 경로 체크
cd kafka_2.13-3.1.0/bin
pwd

# PATH 등록
nano .bashrc

# .bashrc 최하단 환경변수 추가
PATH="$PATH:/home/ygs/kafka_2.13-3.1.0/bin"
# 환경변수 추가 후 linux 재로그인, PATH 체크
echo $PATH 

 

Zookeeper 이용하여 실행

# 주키퍼 실행
zookeeper-server-start.sh ~/kafka_2.13-3.1.0/config/zookeeper.properties

# kafka 실행[]()
kafka-server-start.sh ~/kafka_2.13-3.1.0/config/server.properties

# kafka, zookeper 설정, kafka 로그 및 zookeper 데이터 디렉토리 설정 가능
nano kafka_2.13-3.1.0/config/zookeeper.properties
nano kafka_2.13-3.1.0/config/server.properties

 

KRaft 모드

#PATH 등록 상태에서

# 클러스터 uuid 생성
kafka-storage.sh random-uuid
# EQhLcEdZTku0cEYDOdBqxg

# storage format, 초기화
kafka-storage.sh format -t ${uuid} -c ~/kafka_2.13.3.1.0/config/kraft/server.properties

# 실행
kafka-server-start.sh ~/kafka_2.13.-3.1.0/config/kraft/server.properties

 

WSL2 네트워킹 버그 해결

# 아래 오류메시지, ipv6 문제
# Connection to node -1
# could not be stablished

# 브로커 정지후 ipv6 비활성화 필요
sudo sysctl -w net.ipv6.conf.all.disable_ipv6=1
sudo sysctl -w net.ipv6.conf.default.disable_ipv6=1

vi config/server.properties # or nano
# 리스너 수정 localhost:9092 example
listners=PLAINTEXT://localhost:9092



# ------------------------- 또는 아래와 같이 처리하여 ipv6 유지

sudo sysctl -w net.ipv6.conf.all.disable_ipv6=0
sudo sysctl -w net.ipv6.conf.default.disable_ipv6=0
listners=PLAINTEXT://[::1]:9092