준비하기

kafka는 Java버젼으로 구동되기떄문에 OS별로 자바를 셋팅하고 실행하는 방식의

차이일뿐 kafka를 사용하는 방식은 동일합니다. 여기서는 윈도우 기준으로 설명하겠습니다.

download

사용하고 싶은 버젼을 다운로드 받고, 특정경로에 압축을 풉니다.

ex> C:\datatool\kafka_2.12-1.0>

윈도우 환경 변수에, 어느 디렉토리에건 실행할수 있게 path를 추가해줍니다.

C:\datatool\kafka_2.12-1.0\bin\windows

C:\datatool\kafka_2.12-1.0> 경로에서 각 서버들을 실행하겠습니다.

zookeeper-server-start config/zookeeper.properties

kafka-server-start config/server.properties

kafka가 잘 실행되는지 Topic 생성을 통해 확인가능합니다.

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

특정 토픽에 메시지 생산모듈을 작성한후

특정 토픽에서 메시지큐처리가 되는지 체크합니다.

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning