10초마다 메시지를 Consumer로 전송하는 Producer 예제를 만들도록 하겠습니다. 1. 프로젝트 설정 앞선 예제와 동일하게 https://start.spring.io/ 사이트에서 springboot-kafka-producer 프로젝트를 생성해줍니다. 프로젝트 생성 후 프로젝트 구조는 아래와 같습니다. 2. 소스 코드 application.properties server.port=10001 spring.output.ansi.enabled: always bootstrap-servers=localhost:9092,localhost:9093,localhost:9094 KafkaProperties.java package com.roopy.config; import lombok.Data; import or..

지금까지 Zookeeper, Broker 설정 및 kafka console을 이용하여서 Producer, Conumer를 테스트해봤습니다. 이번에는 Springboot를 이용하여서 Consumer를 작성해보도록 하겠습니다. 1. 프로젝트 설정 https://start.spring.io/ 사이트에서 아래와 같이 프로젝트를 생성하여 줍니다. 프로젝트 생성 후 프로젝트 구조는 아래와 같습니다. 2. 소스 코드 application.properties spring.output.ansi.enabled: always bootstrap-servers=localhost:9092,localhost:9093,localhost:9094 bootstrap-servers는 앞에서 3개의 Broker 주소입니다. KafkaPro..

본 예제 테스를 위해서는 앞에서 설명한 Zookeeper와 Kafa서버가 실행되어 있어야 합니다. 지금까지 Zookeeper, Kafka 설치 및 설정을 완료 하였습니다. 현재까지 설정에 대한 확인을 위하여서 Topic 생성 후 Producer와 Consumer 테스트를 해보도록 하겠습니다. Topic 생성 testTopic 생성을 위해서 C:\kafka\kafkaNode1 폴더로 이동한다. testTopic 생성 .\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --create --topic testTopic --partitions 3 --replication-factor 3 test..

RabbitMQ는 메세지 브로커 이다. 쉽게 이해하기 위해서 우체국으로 생각할 수 있다. 원하는 사람에게 메세지를 전달하기 위해 메세지를 작성하고 우체국 또는 우편함에 우편물을 넣으면 우리가 원하는 사람에게 메세지가 전달 될 것이다. 아래 그림은 우리가 작성 할 예제 프로그램에 대한 흐름이다. PRODCUER는 메세지를 보내는 사람이 될 것이고 우리가 전달할 메세지는 Broker인 RabbitMQ의 Queue에 메세지가 저장되고 Consumer에게 메세지가 전달 될 것이다. 프로젝트생성 기본적인 자바 프로젝트 생성한다. 프로젝트 구조는 아래와 같다. PRODUCER 메세지를 전송하기 위한 Send.java 프로그램을 작성한다. package com.rabbitmq.tutorials.chap01; impo..