찰떡개발자 코딩

kafka download 및 간단한 topic 발행 및 consumer의 event consume을 Test해볼차례이다.

Kafka url : https://kafka.apache.org/downloads

kafka 버전은 관계없이 테스트해보기 위해서 받은거기때문에 상황에 맞게 버전선택을 하면 될것이다.

우선 2.8.1 버전을 받아서 원하는 위치에 설치해준다.

다운로드 후 zookeeper를 먼저 실행시켜준다.

위치는 kafka/bin/windows에 보면 있으니...! .bat file을 config 파일을 함께 구동시켜준다.

./zookeeper-server-start.bat ..\..\config\zookeeper.properties

그후 kafka를 실행시켜주면된다. 실행은 아주 간단하다.!!

 ./kafka-server-start.bat ..\..\config\server.properties

이렇게 하면 필요한 준비는 다 끝났다.

이제 Producer로 Topic을 만들어 이벤트를 Publishing 하고 해당 Topic을 Subscribe 하고있는 Consumer가 메세지를 출력하는 예제를 해보자!

터미널 하나를 열어 Topic을 발행해놓자!

./kafka-topics.bat --create --bootstrap-server localhost:9092 --topic testGeorge
Created topic testGeorge

Producer 역할을 할 터미널을 하나 키고, 해당 Topic에 메세지를 발행해보자

./kafka-console-producer.bat --broker-list localhost:9092 --topic testGeorge

producer를 만들고, 입력을 기다리는상태가 된다. 이때 원하는 메세지를 발행하면 끝!

자 producer가 발행한 메세지를 subscribe하는 consumer를 만들어보자.

./kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testGeorge --from-beginning

특정 Topic에 Producer가 발행한 메세지를 Topic을 구독하고 있는 Consumer가 잘 가져와서 출력하는것을 볼수 있다.

지금부터 Producer가 발행하는 메세지를 실시간으로 Consumer창에서 볼수있으니 가지고 놀면된다~!

다음엔 Spring boot에 websocket을 간단하게 붙여서 Producer가 발행한 메세지를 Consumer가 가져오고, 그 메세지를 Weboskcet을 통해 Client에게 보내주는 예제를 진행해볼 예정이다~!

간단한 구조이지만, 사용법이 쉽지 고려해야될 것들이 많은 구조이기떄문에 자세하게 공부해봐야겠다...