참고 사이트
https://herojoon-dev.tistory.com/118 - 설치
https://zzang9ha.tistory.com/301 - 실행(테스트)

Apache Kafka
▲ 위 링크에서 가장 최신 버전의 Scala 2.13 압축파일 다운로드 (3.3.1 version)

압축 해제한 파일을 (base)경로인 C:/Users/USER 에 저장

작업 경로를 C:/Users/USER/kafka_2.13-3.3.1로 바꿔주기
→ cd kafka_2.13-3.3.1

        ————————————————— 기본 세팅 끝 ——————————————————

1. Zookeeper 실행

C:/Users/USER/kafka_2.13-3.3.1 경로에서…

bin\windows\zookeeper-server-start.bat config\zookeeper.properties  # zookeeper 실행 명령어

▼ 실행결과
started가 적혀있으면 지금 실행되고 있다는 중

‼️‼️ 창 닫으면 안됨 ⭐⭐⭐

zookeeper가 정상적으로 실행되었는지 port확인

windows에서 2181포트가 실행되었는지 확인
→ netstat -na | findstr "2181"

 

2. Kafka 실행

C:/Users/USER/kafka_2.13-3.3.1 경로에서…

bin\windows\kafka-server-start.bat config\server.properties   # kafka 실행 명령어

▼ 실행결과
started가 적혀있으면 지금 실행되고 있다는 중

‼️‼️ 창 닫으면 안됨⭐⭐⭐

kafka가 정상적으로 실행되었는지 port확인

windows에서 9092포트가 실행되었는지 확인

netstat -na | findstr "9092"
📝 주키퍼의 default 포트는 2181이고, 카프카의 default 포트는 9092 이다.

 

3. Kafka 테스트

새로운 powershell 열기

C:/Users/USER/kafka_2.13-3.3.1 경로 설정

• Kafka broker에 Topic 생성하기
  • create 옵션으로 test1라는 토픽을 생성하고, bootstrap-server 옵션으로 카프카 서버인 9092 포트에 연결
  • .\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test1
• 생성된 Topic 확인
  • .\kafka-topics.bat --list --bootstrap-server localhost:9092

※ Kafka topic이 생성되면 C:\tmp\kafka-logs 위치에도 topic의 폴더가 생성