카프카 윈도우

apache kafka(아파치 카프카)

- open-source message broker

- 메시지 전송, 메시지 검증, 메시지 라우팅 프로젝트

 

윈도우 환경에서의 카프카 서버 실행
JAVA_HOME이 환경변수에 잡혀있어야 한다.(자바 sdk 경로)

다운로드
- http://kafka.apache.org/downloads.html 에서 binary 버전을 다운받는다.

서버 실행(주키퍼와 카프카가 모두 실행되야 함)
1. 시작-실행-cmd 엔터
2. cd 카프카 경로/bin/windows (ex: C:\dev\kafka_2.9.2-0.8.2-beta\bin\windows)
3. 주키퍼, 카프카 실행(cmd를 2개 띄워서 각각 실행)
zookeeper-server-start.bat ../../config/zookeeper.properties
kafka-server-start.bat ../../config/server.properties

로컬에서 테스트 명령어(주키퍼와 카프카 실행 된 상태에서 각각 cmd창 띄운 상태에서 하면 됨)

토픽 생성
kafka-topics.bat --zookeeper localhost:2181 --topic test --create --partitions 1 --replication-factor 1

 

토픽 리스트확인
kafka-topics.bat --zookeeper localhost:2181

 

프로듀서 생성
kafka-console-producer.bat --broker-list localhost:9092 --topic test
컨슈머까지 생성 후 메시지 입력하면 컨슈머로 전송됨

 

컨슈머 생성 
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning