윈도우(Windows)에서 카프카(Kafka) 간단 테스트하기

이번에는 PowerShell을 이용해서 윈도우에서 카프카 producer와 consumer를 간단히 테스트 해보겠습니다.  Zookeeper와 Kafka 서버를 시작합니다. (잘 기억이 안 나신다면 여기를 클릭) 그리고 파워쉘을 엽니다.

• kafka 폴더 안에 있는 windows 폴더 안으로 들어갑니다.

• kafka-topics.bat을 실행시키면 사용하실 수 있는 옵션(option)을 보여줍니다.

• 카프카 브로커(broker)에 토픽(topic)을 생성합니다.   .\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test  (create 옵션으로 test란 이름의 토픽을 만들 것이고 bootstrap-server 옵션으로 localhost의 9092 포트에 연결할 것입니다.) 그리고 잘 만들어졌는지 확인합니다.   .\kafka-topics.bat --list --bootstrap-server localhost:9092

• 프로듀서(producer)를 실행하여 test란 토픽에 메세지를 보낼 것입니다.   .\kafka-console-producer.bat  --broker-list  localhost:9092 --topic test (broker-list 옵션에 유의하세요.)를 실행하고 > 모양이 뜨면 메세지를 입력합니다.

• 컨수머(consumer)를 실행하여 test란 토픽에서 메세지를 가져올 것입니다. .\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning (--from-beginning 옵션을 넣지 않으면 조금 전에 보낸 메세지는 안보입니다.) 

• 기존의 consumer를 Ctrl + C 로 종료하고 --from-beginning 없이 재실행합니다. 메세지가 보이지 않고 커서(cursor)만 깜빡입니다. 

• producer와 consumer 창을 나란히 띄우고 producer에서 메세지를 입력하면 실시간으로 consumer가 broker의 test란 토픽에서 메세지를 가져와서 보여줍니다. (기존에 입력한 메세지는 가져오지 않습니다.)