기존에는 하나의 DB를 사용하기 때문에 데이터 동기화를 고려할 필요가 없었지만 Order-service에사 사용하는 DB와 Catalog-service에서 사용하는 DB가 다른 경우를 데이터 동기화 필요

• Order-Service에서 주문한 만큼 Catalog-Service에서 수량이 차감 되어야 한다.

<aside> 📌 Order Service에 요청된 주문 수량 정보를 Catalog Service에 반영 Order Service에서 Kafka Topic으로 메시지 전송 → Producer Catalogs Service에서 Kafka Topic에 전송 메시지 취득 → Consumer

</aside>

Catagory-Service(Consumer)

Order-Service에서 등록한 Topic을 처리하기 위한 Consumer

• 주문 수량만큼 DB에서 차감해야 한다.

Spring-kafka 추가

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

Kafka-Consumer-Config 설정

1. 접속 정보 설정

kafka 서버와 연동될 접속 정보 메소드 생성

만약, 여러 개의 컨슈머가 데이터를 가져갈 때 그룹 설정이 필요함

• 해당 프로젝트에서 필요는 없지만 명시는 함