본문 바로가기

분류 전체보기285

[TIL] 프로젝트 15일차.. 프로젝트 리팩토링 및 고도화 고민하기! 🌞 오늘은 어떤 하루였지..오늘은 팀원분이 풀리퀘 올리고 merge 된 코드를 pull 받아서 내 코드를 옮기는 작업을 했다.지금까지는 내가 개인적으로 테스트 Controller를 만들고 거기서 작업을 진행하고 있었다. 하지만 이제는 팀원의 코드와 합쳐야 하니 내 코드가 잘 동작할 수 있도록 옮기는 작업을 했다!완벽하게 다 옮기려고 했지만 결제 파트에서 넘어오는 DTO를 예상할 수 없어서 로직을 다 작성하지 못하고 우선은 틀만 잡아두고 팀원의 양식대로 나머지 코드를 작성했다.case INVENTORY_DECREASE -> { // todo 결제 파트에서 전달되는 payload 구조 확인 후 DTO 정의 // log.info("📥 Kafka 재고 감소 메시지 수신: {}", message);.. 2025. 6. 4.

[TIL] 프로젝트 12일차.. 재고 감소 로직과 배송 생성 로직 연결 마무리하기! 🌞 오늘은 어떤 하루였지..오늘은 진짜 진짜 마지막으로 재고 감소 로직과 배송 생성 로직을 연결하는 작업을 마무리했다.주문을 생성하는 시점에서 배송 생성에 필요한 데이터를 모두 담고 결제 파트로 넘겨주고 있었다. 그렇다면 어제 계속 고민했던 배송 생성에 필요한 데이터를 가져오는 데 문제가 없어 보였다.주문 → 결제 → 재고 감소 → 배송까지 오면서 데이터를 모두 담고 있기 때문에 DB를 조회해서 하지 않아도 RequestDTO 내에 전부 있어서 Service의 로직이 정상적으로 동작할 수 있다.그렇다면 결제에서도 데이터를 잘 넘겨주는지 확인하고 넘겨주지 않는다면 담당 팀원에게 부탁해서 데이터 그대로 넘겨달라고 요청하면 될 것 같다.그럼 난 그 안에서 재고 감소 로직 이후에 배송 생성 요청 메시지를 보낼.. 2025. 6. 4.

[메시지 브로커] 나만 모르는 줄 알았던 메시지 브로커.. 📨 메시지 브로커란 무엇일까..?서로 다른 시스템이나 프로그램끼리 "메시지(데이터)"를 주고받을 수 있도록 중간에서 전달해 주는 소프트웨어이다.쉽게 말해서 데이터를 전송하고 싶은 시스템과 수신할 시스템 사이에 중간 전달자 역할을 수행한다. 📨 그렇다면 메시지 브로커가 왜 필요할까??❌ 기존 방식 : A 프로그램 → 직접 B 프로그램 호출👉 A와 B가 서로 강하게 연결된다. (Coupling)👉 B가 느리거나 장애가 나면 A도 영향을 받는다.👉 비동기 불가능 → 확장성/유지보수가 어렵다.✅ 메시지 브로커 사용 : A 프로그램 → 메시지 브로커 → B 프로그램👉 A는 메시지만 보내면 끝이다. (B가 죽어 있어도 괜찮다.)👉 A와 B가 독립적으로 동작할 수 있다. (비동기 처리가 가능하다.)👉.. 2025. 5. 30.

[TIL] 프로젝트 11일차.. 드디어 재고 감소랑 배송 생성이랑 연결을?! 🌞 오늘은 어떤 하루였지..오늘은 드디어 재고 감소 로직이랑 배송 생성 로직을 Kafka를 활용해서 연결하려고 했다!근데 막상 연결하려고 설계를 하다 보니 문제가 발생했다.. 배송을 생성할 때 필요한 데이터들을 전부 받아올 수 없는 것이었다..배송을 생성하기 위해서는 orderId, sellerId, senderId, addressId, deliveryRequest 가 필요하다.하지만 지금 당장 받아올 수 있는 것은 orderId와 sellerId이고 나머지는 받아올 수 없는 것이었다..그래서 프로젝트를 같이 진행하는 팀원들과 얘기해본 결과 Sender(출고지(물류센터))와 Seller(판매자) 사이에는 연관관계를 추가하여 판매자가 어느 출고지(물류센터)로 상품을 보내서 관리해야 하는지 확인해야 했다... 2025. 5. 29.

[트러블슈팅] 예외 메시지가 null로 출력된 문제.. 🐛 문제 현상Kafka Consumer에서 ConflictException이 발생했을 때, 로그 메시지가 null로 출력됐다.⚠️ 재고 부족으로 메시지 처리 실패: null→ getMessage()로 예외 메시지를 출력했지만, null이 나왔다. 🔍 원인 분석✅ 기존 코드 구조public class ConflictException extends CustomRuntimeException { public ConflictException(ErrorCode errorCode) { super(errorCode); // message는 전달하지 않음 }}@Getter@RequiredArgsConstructorpublic class CustomRuntimeException extends .. 2025. 5. 28.

[트러블슈팅] Kafka Consumer 재시도 실패로 인한 메시지 유실.. 🐛 문제 현상Kafka 메시지를 정상적으로 수신한 후 처리 과정에서 예외가 발생했을 때, 같은 로그가 반복 출력되면서 결국 메시지가 폐기되었다..Backoff FixedBackOff{interval=0, currentAttempts=10, maxAttempts=9} exhausted for stock-management-topic-0@3 📌 주요 로그Listener method 'public void ... listen(...)' threw exception...Caused by: turtleMart.global.exception.ConflictException...DefaultErrorHandler : Backoff FixedBackOff{...} exhausted 🔍 원인 분석Spring Ka.. 2025. 5. 28.

이전 1 2 3 4 5 ··· 48 다음

티스토리툴바