이전 예시에서는 각각 사용하는 DB를 동기화 처리 하였지만 만약 사용하는 서비스의 인스턴스가 여러개 인 경우에 대해 처리를 해본다.

사용자(User-Service)가 주문(Order-Service)을 등록할 경우 인스턴스가 여러 개 인 경우 라운드 로빈 방식으로 등록이 되어 동기화 처리 X

• 예를 들어, 5번의 주문을 했다면 1, 3, 5번의 주문은 A 인스턴스의 설정된 DB로 저장이 되고 2, 4번은 B 인스턴스의 설정된 DB로 저장
  • 단일 데이터 베이스를 사용한다면 문제는 없다.

데이터를 동기화 시키기 위해 Order Service에 요청된 주문 정보를 DB에 저장하는 것이 아닌 Kafka Topic으로 전송한다.

• Kafka Topic에 설정 된 Kafka Sink Connect를 사용해 DB에 저장 → 데이터 동기화

Order Service의 Producer에서 발생하기 위한 메시지 등록

이번 예시에서는 주문 정보를 DB로 직접 전송 시키는 것이 아닌 Kafka로 전달 후 Sink Connect를 이용해서 DB로 데이터를 전달

먼저 전달할 메시지를 만들어야 하는데 메시지는 String 타입의 Json 형식으로 되어 있어 형식을 맞춰야한다.

Schema : 데이터가 전달 될 DB 테이블의 정보를 작성

Field : 테이블의 컬럼명과 자료형 타입

Payload : DB에 Insert 할 데이터의 정보(Param)