앞에서는 Kafka의 개념에 대해서 정리했는데 Spring Boot 에 실제로 어떻게 적용해서 사용하는지 코드와 함께 정리해보려고 한다! 1. dependency & application.yml 추가//kafkaimplementation("org.springframework.kafka:spring-kafka") bootstrap.servers 설정은 클라이언트가 접근하는 토픽 파티션의 메타데이터를 요청하기 위한 설정입니다. kafka: bootstrap-servers: localhost:29092예를 들어 bootstrap-servers : broker1:9092,broker2:9092,broker3:9092 로 설정되어 있다면 클라이언트는 broker1:9092부터 메타데이터를 요청하고 실패하면..
사이드 프로젝트를 진행하면서 결제알림,채팅알림 등 다양한 알림 처리에 대해 어떤 툴을 사용할까 고민을 하다가 Kafka 를 적용하게 되었다. 우선 Kafaka 가 무엇인지에 대해 설명하면서 왜 메시지 툴을 사용하여야 하는지 알아보도록 하자~ 0. 개발 환경Back-end : java17IDE : intelliJ 2023.1CI/CD : gitActionAWS 1. Kafka 에 대해서카프카는 실시간, 이벤트 기반 애플리케이션 개발을 가능하게 하는 대규모 데이터 스트리밍 및 메시지 플랫폼입니다. 이는 대량의 데이터를 안정적으로 처리하고, 여러 시스템 간에 데이터를 신속하게 전송하고 실시간으로 데이터를 처리할 수 있는 기능을 제공합니다.카프카는 분산형 메시지 큐로서 데이터를 프로듀서(Producer)가 생성..
콘솔 로그에 쿼리가 찍히고 있는데, 현재 문에 대해서는 빈값으로 찍히고 있다.AND USER_NAME IN ( '', '', '') 그렇다 보니 디버그 할 때 불편해서 개선해보기로 했다! 🤩 1. src/main/java/config/spring/mybatis.yml mybatis bean 설정을 xml 로 설정되어 있고, query문을 찍어주고 있는 Interceptor 부분이 MybatisLogInterc..
프로젝트 진행 중에 Exception 이 발생하면 로그테이블에 저장해주는 로직을 개발해야 하는 상황이었다. 그래서 예외 처리를 @ExceptionHandler 를 통해 관리하고 @Aspect 어노테이션을 붙인 클래스에서 로그테이블을 저장 하는 흐름으로 개발 했는데 문제가 발생하였다. 😭 바로 @RequsetBody 를 통해 들어온 파라미터를 받아서 로그에 저장해야 하는데 현재 개발되어 있는 파라미터로는 요청 파라미터를 받을 수 없어서 찾아보던 중 HttpServletRequestWrapper 를 통해 값을 읽어오는 방법을 알게 되었음! (유레카😲)상황Controller @PostMapping("/approval") public CardResponse paymentApproval( ..
