데이터 동기화 Orders → Catalogs
- Orders Service에 요청된 주문의 수량 정보를 Catalogs Service에 반영한다.
- Orders Service에서 Kafka Topic으로 메시지 전송 → Producer
- Catalogs Service에서 Kafka Topic에 전송된 메시지 취득 → Consumer
- Orders Service에서 Message Queuing Service에 상품 수량 관련 정보를 전달한다.
- Kafka Topic이 그 데이터를 가지고 있다가, Topic을 등록한 consumer가 변경된 데이터 값을 가져간다.
- consumer table에 반영을 한다.
implementation 'org.springframework.kafka:spring-kafka'
Orders Service 2개 기동
- Users의 요청 분산 처리
- Orders 데이터도 분산적으로 저장 ➔ 동기화 문제 발생
- Orders Service에 요청된 주문 정보를 DB가 아니라 Kafka Topice 으로 전송
- Kafka Topic에 설정된 kafka Sink Connect를 사용해 단일 DB에 저장 ➔ 데이터 동기화