Transaction OutBox Pattern 구현

참고로 그냥 내 생각대로 만든 코드임 Polling 방식임 그림 그림만 보면 그냥 테이블 2개 만들어서 저장하고 OUTBOX 테이블을 읽어서 원하는 토픽으로 보내기만 하면 된다. 간단한...

코드 구현 Controller 및 요청 DTO 간단하게 만들어주자 domain 상품 테이블에 저장할 Product Entity OutBox 테이블에 저장할 OutBoxMessage Entity Kafka로 보낼 메시지 Service 같은 물리 트랜잭션에 속할 수 있게 트랜잭션 어노테이션 사용하고 Product와 OutBox Message를 저장해 준다.. 그림만 보면 이게 전부 메시지 릴레이 및 발행 cron 식을 사용해서 5초마다 읽을 수 있게 추가함 또한 jpa entity dirty checking 사용해야 되니 트랜잭션 어노테이션 사용함 위의 코드를 보면 sent가 False인 것만 가져와서 kafka로 보낸 다음에 보냈다고 true로 표시를 바꿔준다. true로 바꿔주면 다음번에는 fi...