Producer에서 전송한 배달정보를 수신하여서 WebSocket으로 배달정보를 전송한다. Spring Kafka Consumer Project 서버 설정을 위한 application.yml server: port: 9001 spring: output: # Console Color 표시 ansi: enabled: ALWAYS kafka: consumer: bootstrap-servers: localhost:9092 Kafka consumer configuration package com.roopy.delivery.consumer.config; import lombok.RequiredArgsConstructor; import org.apache.kafka.clients.consumer.ConsumerCon..

라이더들은 배달 정보를 앱을 통해 전송한다. 앞에서 보았지만 앱 대신에 Swagger를 이용하여서 메세지를 전송한다. Zookeeper 설치 및 설정 Zookeeper 설치 및 설정은 아래 글을 참고 하시면 됩니다. https://jydlove.tistory.com/82 이번 프로젝트에서는 zNode1 하나만 설정 하여서 프로젝트를 진행하도록 하겠습니다. Kafka 설치 및 설정 Kafka 설치 및 설정은 아래 글을 참고 하시면 됩니다. https://jydlove.tistory.com/83 이번 프로젝트에서는 kafkaNode1 하나만 설정 하여서 프로젝트를 진행하도록 하겠습니다. Spring Kafka Producer Project 서버 설정을 위한 application.yml server: port..

본 예제 테스를 위해서는 앞에서 설명한 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..

Zookeeper의 역할은 많겠지만 Broker와의 관계에서는 가장 큰 역할은 분산 메시 지큐의 정보를 관리해주는 역할을 합니다. 예제를 위하여서 노드는 3개의 노드를 설정합니다. 다운로드 및 폴더 설정 Zookeeper 설치는 Window10 기준이며 버전은 3.7.0입니다. 아래의 사이트에서 프로그램을 다운로드합니다. https://zookeeper.apache.org/releases.html#download