시작하며안녕하세요. 개발자 Stark입니다. 최근 저는 MSA 프로젝트에 분산추적을 적용하기 위해 Jaeger와 Opentelemetry라는 오픈소스의 소스코드를 하나하나 뜯어보며 분석하고 있습니다. 이렇게 오픈소스를 분석하는 과정을 진행하면서 저의 코드를 보는 시야가 이전과는 많이 달라진 것을 느낄 수 있었습니다. 특히 분석하면서 이 오픈소스가 실제로는 어떻게(how) 동작하는지에 대한 것들을 알 수 있다는 것이 너무 좋았습니다. 이 과정을 겪으면서 앞으로 내가 사용하는 오픈소스는 꼭 분석하고 사용하겠다는 마음을 다지며 다음 분석 타겟은 뭐로 할지 고민하던 도중 프로젝트에서 이미 사용 중인 Apache Kafka의 상세한 동작 원리를 알아야겠다는 생각이 들었습니다. 지금까지 SpringBoot에서 ka..

시작하며안녕하세요. 개발자 stark입니다. Apache Kafka를 사용하다 보면 메시지 전송 보장 방식(message delivery guarantee)이라는 개념을 접하게 됩니다. 이는 어떤 메시지가 몇 번 전달되는지를 보장하는 방식으로, 애플리케이션이 데이터를 처리하거나 주고받을 때 '중복 처리'나 '데이터 유실'을 어떻게 다룰 것인지를 결정하는 중요한 요소입니다. 이번 포스팅에서는 Kafka의 대표적인 메시지 전달 보장 방식인 At Most Once(최대 한 번), At Least Once(최소 한 번), Exactly Once(정확히 한 번)이 무엇을 의미하는지 기본 개념부터 이해해 봅시다.  메시지 전달 보장 방식이란?'메시지 전달 보장 방식'은 시스템이 메시지를 처리하거나 전달할 때 발생할..

오늘은 Kafka 소스코드를 분석하다 발견한 Locale.ROOT의 사용 사례를 다뤄보려고 합니다. 이 코드는 처음 봤을 때는 뭔가 신기했지만, 실제로 왜 사용되었는지를 깊이 이해한 후에는 그 중요성을 충분히 깨달을 수 있었습니다.제가 글로벌 서비스를 운영할 때 각 지역별로 다른 시간을 보여주기 위해 JavaScript에서 Locale을 다룬 경험은 많았지만, 백엔드 개발을 하며 Java에서 이렇게 명시적으로 Locale을 설정한다는 것은 생각해 본 적이 없었습니다. (UTC와 Zoned는 다뤄봤지만 Locale만을 직접적으로 다뤄본 적은 없습니다.) 그래서 이번 포스팅을 통해 그 내용을 간단히 공유해 보겠습니다.  Kafka의 AcknowledgeType Enum 코드 분석아래 코드는 오픈 소스 Kaf..

Docker를 통해 Kafka를 실행해 보자📌 서론이전에도 kafka 세팅에 대해 포스팅을 한 적이 있지만 가장 최근에 새롭게 세팅을 하면서 알게 된 점들을 정리해 봤다.특히 port를 설정할 때 내부, 외부로 구성하는 점이 굉장히 중요했다. 이 부분은 실수로 잘못 설정하면 외부에서는 아예 접근조차 불가능했다.세팅은 loacl에서 진행했으며 docker-compose를 사용해서 m2 max 맥북에서 실행했다.만약 SpringBoot에 연결하는 방법이 궁금하다면 이 글을 확인하자 (SpringBoot3.x.x) [Kafka] SpringBoot3.x.x에서 Kafka 연동하기스프링 부트 3.1.2에 Kafka를 세팅해 보자📌 서론이전 포스트를 통해 docker-compose로 Kafka를 띄웠다.이번..

SpringBoot 설정을 잘못해서 kafka 연결이 안 되는 문제를 해결했다. 📌 서론 이번 포스트는 SpringBoot의 application.yml에 kafka 설정을 잘못해서 오류가 발생한 부분을 수정한 내용이다. 발생했던 오류는 스프링 서버를 실행했을 때 consumer의 연결이 불가능했던 문제다. 1. SpringBoot에 KafkaListener 코드를 작성하자 kafka를 실행했는데 에러가 발생했다. 이건 연결 에러인데 로그만 봐도 Consumer관련 오류인 것을 알 수 있다. [Consumer clientId=consumer-error-handler-group-1, groupId=error-handler-group] Bootstrap broker localhost:9092 (id: -1 ..

SpringBoot에서 kafka를 통해 슬랙에 에러 알림을 보내보자 📌 서론 이번 포스트를 읽기 전 2가지 사항을 모두 완료했는지 확인해 보자 1. Kafka 세팅 2. 슬랙 webhook 세팅 이번 포스트에서는 아래와 같은 작업을 하는 코드를 알아볼 것이다. 1. 예외가 발생하면 SpringBoot에서 kafka로 메시지를 produce 한다. (이전 포스트에서 확인가능) 2. SpringBoot내부에 작성한 kafkaListener코드를 통해 이 예외 메시지를 consume 한다. 3. kafkaListener에서는 slack의 webhook url로 메시지를 보내서 알림이 울리도록 한다. 1. 먼저 SpringBoot에 kafka를 연동하자 [Kafka] SpringBoot3.x.x에서 Kafka..

슬랙의 WebHook 세팅하기 📌 서론 이전 포스트를 통해 SpringBoot에 Kafka 설정을 완료했다. Slack에 알림 메시지를 띄우기 위해서는 webhook url이 필요하다. 이번 포스트에서는 Slack에서 webhook url을 발급받는 방법을 알아보자. 이번 포스트에는 Kafka와 관련된 것이 하나도 없지만 세팅한 이유가 Kafka에서 webhook을 사용해서 메시지를 보내기 위함이다. 이전 포스트에서 이어지는 내용이라는 점을 알아줬으면 좋겠다. [Kafka] SpringBoot3.x.x에서 Kafka 연동하기 스프링 부트 3.1.2에 Kafka를 세팅해 보자 📌 서론 이전 포스트를 통해 docker-compose로 Kafka를 띄웠다. 이번 포스트에서는 SpringBoot3.1.2에 세..

스프링 부트 3.1.2에 Kafka를 세팅해 보자📌 서론이전 포스트를 통해 docker-compose로 Kafka를 띄웠다.이번 포스트에서는 SpringBoot3.1.2에 세팅한 카프카를 연결하고 우리가 원했던 대로 예외가 발생하면 예외 메시지를 카프카의 producer로 발행한 다음 docker-desktop의 콘솔을 통해 consumer로 메시지를 잘 받는지 확인했다.이번 포스트에서는 그 과정을 설명한다.이전 포스트를 통해 docker-compose로 kafka를 실행하고 오도록 하자 (M1 mac 기준) [kafka] Docker로 카프카 실행하기 (KRaft 모드)Docker를 통해 Kafka를 실행해 보자📌 서론이전에도 kafka 세팅에 대해 포스팅을 한 적이 있지만 가장 최근에 새롭게 세..