1. - orderService 2개 기동후 kafka-sink-connect를 이용하여 mariaDB에 저장하기

• 오더 서비스는 jar 파일로 빌드하여 2개를 띄우고 진행하였다.

• 다음으로 example-order-topic으로 커넥터를 만들고 주문 요청을 통해 해당 db가 생기고 업로드 되는지 consumer.bat을 통해서 확인과 하이디 sql에서 확인하였다.
• 카프카 커넥터에 db 데이터 입력 요청이 메시지로 잘 전달되고 마리아db에 저장되는것 을 확인할 수 있다.

2. - 주문 수량이 남은 재고량보다 많을 경우 오류를 만들자

• 주문을 담당하는 order-service의 createOrder 메서드를 재고 품목정보를 가진 Catalog-service의 api를 불러오고

• 재고와 주문량의 비교를 통해 재고가 부족하면 에러를 띄우게 만들었다.

• Catalog-service에서 상품의 Id를 통해 상품정보 객체를 불러와주는 api를 생성하였다. (해당 api 메서드만 첨부)

  • CatalogController

• 타 서비스의 api를 가져오기위해 OpenFeign의 의존성을 추가하였고 catalog-service의 FeignClient를 선언하는 클래스를 만들어줬다.

  • CatalogServiceClient (Feign Client)

• 해당 feign 클라이언트를 order-service의 ServiceImpl 클래스에서 사용해주었다.

  (관련된 인터페이스와 repository 로직은 생략)

  • OrderServiceImple (createOrder 메서드)

• 기존 카프카를 통해 작동하던 order api 컨트롤러에 createOrder 메서드를 사용해주면 다음과 같은 포스트맨 요청 결과를 볼 수 있다.

  (테스트 - 주문 수량 : 100 / 남은 재고: 90 - 500 에러 발생)

  

  (테스트 - 주문 수량: 10 / 남은 재고: 90 - 201 created)

  

3. - 2개 이상의 주문 서비스를 가동하고 어느 곳에서 주문을 받았는지 카프카 커넥터를 통해 저장 구현

• Order Entity에 String orderIp 속성을 생성해주었다.

• 카프카를 사용하는 OrderProducer 클래스에서 orderIp라는 필드를 생성했고 send하기위한 Payload에 담아주는 방식으로 구현하였다.

  • 카프카 커넥터를 통해 데이터(payload)를 전달하기 위한 OrderProducer
  • 페이로드 데이터를 저장받기 위한 Payload 클래스

  이 파트가 끝나면 mariaDB에 order_ip 속성이 생긴걸 볼 수 있다.

  

• 이제 OrderServiceImpl에서 주문이 생성될 때 IP주소와 Port를 불러오게 createOrder 메서드에 다음 내용을 추가하였다.

  • OrderServiceImpl - createOrder 메서드

• 추후 주문 요청을 더 시도해보았다.