[Apache Kafka] 로컬 카프카 설치 및 실행 방법 | 주키퍼 실행 | 정상 실행 확인 방법 | 섹션 4-1 | 스터디 3주차

*본 포스팅은 인프런 [데브원영]님의 아파치 카프카 프로그래밍 강의 세션 4를 수강하고 이를 참고해 작성했습니다. 

[아파치 카프카 애플리케이션 프로그래밍] 개념부터 컨슈머, 프로듀서, 커넥트, 스트림즈까지! |

 

1. 실습 준비

 

- 예제 코드 다운로드 

GitHub - bjpublic/apache-kafka-with-java: 아파치 카프카 애플리케이션 프로그래밍 with 자바

 

- 카프카 바이너리 파일 다운로드: 버전은 2.12-2.5.0.tgz

Apache Kafka

 

- 실습 툴 (인텔리제이, iTerm2) 다운로드

 

2. 실습

[1] server.properties 파일 수정하기

 - broker.id = 0 

- listeners 경로를 로컬 호스트의 9092 포트로 설정한다.

- advertised.listeners의 경로를 로컬 호스트의 9092 포트로 설정한다.

 

[2] 로그 파일 디렉토리 생성 및 경로 지정

로그를 저장할 ``data` 디렉토리를 생성한다.

server.properties 파일에서 log.dirs에 방금 data 디렉토리를 생성한 경로로 지정해 준다. 

`cat config/server.properties | grep log.dirs` 명령어를 입력하면 다음과 같이 올바르게 경로가 지정됐는지 확인할 수 있다.

 

[3] 주키퍼 실행하기

- 주키퍼 실행 전 자바가 설치되어 있는지 확인해야 한다.

- 자바가 설치되어 있는 것을 확인했다면 `bin/zookeeper-server-start.sh config/zookeeper.properties` 명령어를 사용해서 주키퍼를 실행한다. 

- 반드시 카프카 브로커 실행 전 주키퍼를 먼저 실행해야 한다. 

 

[4] 카프카 브로커 실행하기

- 주키퍼가 정상적으로 실행된 것을 확인한 뒤 `bin/kafka-server-start.sh config/server.properties`명령어를 사용해서 카프카 브로커를 실행한다. 

 

[5] 정상적으로 작동하는 주키퍼(상), 카프카 브로커(하)

 

 

[6] 카프카 정상 실행 여부 확인

`bin/kafka-broker-api-version.sh --bootstrap-server localhost:9092`명령어를 사용하면 로컬에 띄워진 카프카 브로커를 조회할 수 있다. 

 

[7] 테스트 편의를 위한 hosts 설정 

`etc/hosts` 파일에 `127.0.0.1 my-kafka` 명령어를 추가해 테스트 편의를 위한 호스트 설정을 해준다. 

 

완료!