hyeonq.log

개요통합 결제 서비스를 설계하는 과정에서 Kafka 를 도입하였고,Kafka Request-Reply 분산 환경 메시지 처리 관련 이슈 해결 과정을 적어보려고 합니다. Skills: SpringBoot3.2 , Java17, MySQL, JPA, Spring Kafka 문제 상황현재 대강 그려본 서버 아키텍쳐는 아래와 같습니다. 기본적인 설정은 아래와 같습니다.Gateway 서버: 사용자 요청 수신 및 응답 반환 (2대 - (gateway01, gateway02))Worker 서버: 실제 결제 처리 로직 수행 (2대)Third Party Server: 외부 PG사 APIKafka Cluster: 메시지 브로커 (3 brokers, replication factor=3)Consumer Group: 동일 ..

1. 개요spring 에서는 쉽게 카프카를 사용하기 위해서 kafka 인터페이스를 제공한다그리고 우리는 위 kafka 를 springboot 에서 원활하게 사용하기 위해서 producer, consumer 설정을 잡아줘야 한다 위 설정에서 가장 중요한 message 발행 및 소비시에 필요한 key,value 직렬화 & 역직렬화설정에 대하여 알아보려고 한다 일반적인 카프카 사용시 데이터 흐름을 서버 아키텍쳐로 보면 아래와 같다(간단하게만 그려본 것이다)User --> LB --> WAS --> Kafka --> ConsumerUser 가 서버에 데이터를 보낼 때 보통은 Http Body 에 값을 넣어서 보내고는 한다 kafka 가 아니더라도 일반적인 Http 프로토콜을 사용하여 통신을 할 때 또한 Htt..