[Kafka] 설치 및 테스트

• 환경
  • Windows 11
  • kafka 2.8.0 https://kafka.apache.org/downloads

1. 설치 및 실행

1. 다운로드

위 사이트에서 2.8.0 버전 다운로드 후 원하는 곳에 압축 풀기

• cmd 창 켜기
• 압축 푼 kafka 디렉토리로 이동 cd C:\backendCLASS\99.devEnv\kafka2.8.0

2. zookeeper 실행

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

• 새로운 cmd 창을 띄운 뒤, zookeeper 정상 실행되었는지 port확인
  netstat -na | findstr "2181"

3. kafka 실행

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

• 새로운 cmd 창을 띄운 뒤, kafka 정상 실행되었는지 port확인
  netstat -na | findstr "9092"

 

2. kafka topic 생성

# kafka topic 생성
# bin\windows\kafka-topics.bat --create --bootstrap-server 카프카주소:포트 --topic 지정할토픽이름
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic my-topic

# kafka topic 생성 확인
# bin\windows\kafka-topics.bat --list --bootstrap-server 카프카주소: 포트
bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

• 토픽이 생성되면, C:\tmp\kafka-logs 위치에 해당 topic 폴더가 생성된 것을 확인 할 수 있다.

 

3. 실행 시 오류 해결

• zookeeper, kafka 실행 도중, 입력 줄이 너무 깁니다. , 명령 구문이 올바르지 않습니다. 라는 에러가 뜰 경우
  • kafka 디렉토리 명을 짧게 바꾼다.
  • kafka 디렉토리 위치를 root에 최대한 가깝게(path 길이가 짧도록) 옮긴다.
• 서버 실행 되지 않을 경우
  • zookeeper, kafka를 실행시키면 C:\tmp 위치에 로그 정보가 생성되는데, 이전에 설치되었던 정보가 있을 때 오류가 난다면, tmp폴더를 제거하고 zookeeper와 kafka를 다시 실행시키기
  • 계속적으로 오류가 난다면 다른 버전 다운그레이드하기