반응형
Windows OS에 Kafka를 설치하고 간단하게 서비스를 구현해봅니다.
Kafka 설치: https://dlcdn.apache.org/kafka/2.8.1/kafka_2.12-2.8.1.tgz
Windows에서 3 버전대가 안되서 2.8.1 버전으로 진행 하였습니다
다운로드 후 Powershell, cmd 로 kafka\bin\windows 폴더로 이동합니다.
- zookeeper 서버를 start 합니다.
> .\zookeeper-server-start.bat ..\..\config\zookeeper.properties
- Powershell, cmd 창을 추가로 하나 더 open 하여 kafka 서버를 start 합니다.
> .\kafka-server-start.bat ..\..\config\server.properties
- Powershell, cmd 창을 추가로 하나 더 open 하여 kafka-topics를 이용하여 topic을 생성합니다.
> .\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic code-report
- kafka-topics을 생성 후 해당 topic으로 producer 상태를 만듭니다.
> .\kafka-console-producer.bat --broker-list localhost:9092 --topic code-report
- Powershell, cmd 창을 추가로 하나 더 open 하여 위에서 생성한 topic의 consumer(subscriber) 상태로 만듭니다.
> .\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic code-report --from-beginning
총 4개의 command 창이 열려있습니다. - producer에서 message를 전송하여 consumer가 해당 message를 pull 하는지 확인합니다.