도메인 이벤트 구독

[jangjunha]

2a999b5

주방 서비스.

kafka를 통해 도메인 이벤트 구독.

KitchenServiceConfiguration에서 DomainEventDispatcher를 등록.
DomainEventDispatcher에서 KitchenServiceConsumer를 사용.
RestaurantCreated 도메인 이벤트가 수산되면 KitchenService를 호출하여 메뉴 정보 upsert.

https://eventuate.io/docs/manual/eventuate-tram/latest/getting-started-eventuate-tram.html#_consuming_messages

[jangjunha]

⚠️ 주의사항: 중복 메시지 처리

MessageConsumer를 제공하는 EventuateTramKafkaMessageConsumerConfiguration가 중복 메시지 처리 방법을 명시적으로 구현하기를 원한다(DuplicateMessageDetector).

TramConsumerJdbcAutoConfiguration를 import 하여 SqlTableBasedDuplicateMessageDetector를 사용할 수도 있고,
NoopDuplicateMessageDetector를 import 하여 NoopDuplicateMessageDetector를 사용할 수도 있다.
TransactionalNoopDuplicateMessageDetector도 있다.

TODO: 트랜잭션을 관리하는 DuplicateMessageDetector를 사용하는 경우 메시지 핸들러에서 트랜잭션을 관리(예: @Transactional 사용)해서는 안 된다는데 이유는 알아봐야 할 것 같다.

https://eventuate.io/docs/manual/eventuate-tram/latest/getting-started-eventuate-tram.html#_idempotent_message_consumers