[BigData] kafka - 개발자의 연봉 상승을 위한 공부 (실습1)

kafka 설치는 이전 강의를 확인해주세요!

https://novice-engineers.tistory.com/28

[BigData] kafka - 개발자의 연봉 상승을 위한 공부 (설치)

 

이번 실습은 간단하게 문자 input, output을 확인해 보겠습니다.

1. config 설정

0123456

config 설정

1. C:\[kafka버전] 이동 -> 우클릭 -> 새로 만들기 -> 폴더 -> data 디렉토리 생성

2. data 디렉토리 더블 클릭 -> 우클릭 -> 새로 만들기 -> 폴더 -> kafka 디렉토리 생성 (똑같이 zookeeper 디렉토리 생성)

3. C:\[kafka버전]\config 이동 -> zookeeper.properties 파일을 메모장에 끌어 오기

4. C:\[kafka버전]\data\zookeeper 경로 복사 -> zookeeper.properties 의 "dataDir=path" -> path 부분에 복사한 경로 붙여 넣고 저장 (Ctrl + F 누른 후 dataDir 찾으시면 빨리 찾을 수 있어요!)

5. C:\[kafka버전]\config 이동 -> server.properties 파일을 메모장에 끌어 오기

6. C:\[kafka버전]\data\kafka 경로 복사 -> server.properties의 "log.dirs=path" -> path 부분에 복사한 경로 붙여 넣기(4번과 동일한 방법으로 진행하시면 됩니다!)

7. server.properties의 "zookeeper.connect=localhost:2181"를 "zookeeper.connect=0.0.0.0:2181"로 변경 후 저장

 

2. 실습

01

zookeeper, kafka 실행

1. zookeeper 서버 시작

- C:\[카프카버전]\bin\windows 디렉토리 이동 -> zookeeper-server-start.bat ../../config/zookeeper.properties 입력

(반드시 zookeeper 먼저 실행해주세요)

../../config/zookeeper.properties 부분은 저희가 위에서 설정한 값을 반영해 주기 위해서입니다.

 

2. kafka 서버 시작

- 새로운 cmd창 열기 (위 cmd창 끄면 안 돼요!!!) -> kafka-server-start.bat ../../config/server.properties 입력

../../config/server.properties 이유는 위와 동일합니다! (1과 마찬가지로 cmd창 끄면 안 돼요!!!) 

 

3. topic 생성

토픽 생성

1. topic 생성

- 새로운 cmd창 열기 -> kafka-topics.bat --create --topic test_topic --bootstrap-server localhost:9092 입력

 

2. 생성한 topic 확인

- 새로운 cmd창 열기 -> kafka-topics.bat --describe --topic test_topic --bootstrap-server localhost:9092 입력

 

4. 프로듀서 & 컨슈머 실행 & 확인

01

프로듀서 & 컨슈머 실행 & 확인

1. 프로듀서 실행

kafka-console-producer.bat --topic test_topic --bootstrap-server localhost:9092 입력

 

2. 컨슈머 실행

새로운 cmd창 열기 -> kafka-console-consumer.bat --topic test_topic --from-beginning --bootstrap-server localhost:9092 입력

 

3. 확인

프로듀서 cmd창에서 글 입력 후 컨슈머 cmd창 확인