Kafka를 통한 데이터 동기화

zhzkzhffk·2022년 7월 16일
0
post-thumbnail

데이터 동기화 Orders → Catalogs

  • Orders Service에 요청된 주문의 수량 정보를 Catalogs Service에 반영한다.
  • Orders Service에서 Kafka Topic으로 메시지 전송 → Producer
  • Catalogs Service에서 Kafka Topic에 전송된 메시지 취득 → Consumer

  1. Orders Service에서 Message Queuing Service에 상품 수량 관련 정보를 전달한다.
  2. Kafka Topic이 그 데이터를 가지고 있다가, Topic을 등록한 consumer가 변경된 데이터 값을 가져간다.
  3. consumer table에 반영을 한다.
implementation 'org.springframework.kafka:spring-kafka'

Orders Service 2개 기동

  • Users의 요청 분산 처리
  • Orders 데이터도 분산적으로 저장 ➔ 동기화 문제 발생

  • Orders Service에 요청된 주문 정보를 DB가 아니라 Kafka Topice 으로 전송
  • Kafka Topic에 설정된 kafka Sink Connect를 사용해 단일 DB에 저장 ➔ 데이터 동기화
profile
Backend Developer

0개의 댓글