자바/카프카/2021-08-20/ Kafka 개발환경 설정

Zookeeper 홈 https://zookeeper.apache.org/releases.html 에 접속한다

 

 

 

 

 

 

 

zoo.cfg 파일을 열어서 data 경로를 재조정한다.

 

 

 

주키퍼를 실행한다.

 

 

 

카프카(https://kafka.apache.org/ )에 접속 후 다운로드 받는다.

환경변수를 설정합니다.

cmd 창을 오픈한다

 

새로운 cmd 창을 오픈한다. kafka-console-consumer 창이 된다. 

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hello-kafka

를 입력한다. topic 생성 응답이 뜬다. kafka-topics.bat --list --zookeeper localhost:2181 hello-kafka 를 입력한다.

 

또 다른 cmd 창을 오픈한다. kafka-console-producer 창이 된다. 

kafak-console-producer.bat --broker-list localhost:9092 --topic hello-kafka 를 입력 후 엔터를 친다. 다음 행에서 

> 이 뜬다. consumer 에게 보낼 message 를 입력한다. 실시간으로 해당 메시지가 consumer 에게 보내진다.

 

 

앞서 열었던 kafka-console-consumer 창에 send message 가 출력된다. 

초기 설정값에서 한글은 지원하지 않는다.

 

 

 

 

 

 

 

 

 

 

---

참고자료(REFERENCES)

• ddud2n의 Vlog
• 진짜개발자의 Tistory: Spring Boot - Kafka 설치 및 실행과 Spring Boot 에서 설정
• man_tae windows 환경에서 zookeeper 설치 및 실행
• man_tae windows 환경에서 kafka 설치 및 실행