Event Programming in Spring : Kafka vs Spring Message Broker vs Spring Application Events

1. 카프카 (Kafka)
성격: 외부의 분산 스트리밍 플랫폼 (Distributed Streaming Platform)이자 메시지 브로커

범위: 주로 애플리케이션 간 (Inter-application) 또는 서비스 간 (Inter-service) 통신에 사용

즉, 프로젝트의 다른 마이크로서비스나 외부 시스템과 이벤트를 주고받을 때 적합하다

특징:

- 영속성 (Persistence): 메시지를 디스크에 저장하여 영속성을 보장한다. 컨슈머가 다운되었다가 다시 시작해도 놓친 메시지를 처리할 수 있다
- 확장성 (Scalability): 대량의 데이터를 처리하고 높은 처리량을 가질 수 있도록 설계된다. 여러 브로커로 구성된 클러스터를 통해 수평 확장이 용이하다.
- 내결함성 (Fault Tolerance): 브로커 중 일부가 실패해도 시스템 전체가 중단되지 않도록 설계할 수 있다
- 비동기 (Asynchronous): 이벤트를 발행하는 쪽과 소비하는 쪽이 서로 독립적으로 동작한다
- 복잡성: 별도의 카프카 클러스터 설정 및 관리가 필요하며, Spring 애플리케이션에서는 spring-kafka 라이브러리를 통해 연동한다

 

2. Spring Simple Broker

성격: Spring Framework(Spring Messaging) 내부에서 기본 제공하는 인-메모리(In-memory) 웹소켓 메시지 브로커 (Embedded Message Broker)

범위: 주로 클라이언트 ↔ 서버 간 (Client-to-Server / Server-to-Client) 실시간 쌍방향 통신에 사용된다. 즉, 웹 브라우저나 Mobile App 같은 외부 클라이언트에게 STOMP 프로토콜 기반으로 실시간 메시지를 전달(Push)할 때 적합하다.

특징:

• 실시간 양방향 통신 (WebSocket/STOMP): 웹소켓 세션을 맺은 클라이언트들이 특정 경로(예: /topic/chat)를 구독(Subscribe)하면, 서버가 해당 경로로 메시지를 쏘는 순간 즉시 클라이언트 화면으로 전송된다.
• 비영속성 (Non-persistent): 메시지를 디스크나 별도 공간에 보관하지 않고 서버 RAM(메모리)에서 바로 전달한다. 전달되는 순간 소멸하며, 클라이언트 접속이 끊겨 있는 동안 발생한 메시지는 유실된다.
• 단순성 (Simplicity): 별도의 브로커 서버(RabbitMQ, ActiveMQ 등)를 설치할 필요 없이 Spring Boot 환경에서 SimpleBrokerSpec 설정만으로 즉시 실시간 통신 환경을 구축할 수 있다.
• 단일 인스턴스 제약 (Scale-Out 한계): 서버가 여러 대(Multi-instance)로 확장될 경우, 1번 서버의 Simple Broker와 2번 서버의 Simple Broker는 메모리를 공유하지 않으므로 클라이언트 간 메시지가 교차 전송되지 않는다. (이 경우 RabbitMQ 같은 External Broker로 교체해야 함)

3. Spring Application Events
성격: Spring 프레임워크 내부에 내장된 인-프로세스 (In-process) 메시징 메커니즘

범위: 주로 단일 애플리케이션 내부 (Intra-application)의 컴포넌트 간 통신에 사용된다. 즉, 같은 JVM 내에서 이벤트를 발행하고 소비한다

특징:
- 비영속성 (Non-persistent): 메시지를 별도로 저장하지 않습니다. 이벤트가 발행될 때 리스너가 없거나 실패하면 메시지는 유실된다
- 단순성 (Simplicity): Spring 프레임워크에 내장되어 있어 별도의 설정이나 외부 시스템 없이 쉽게 사용할 수 있다. @EventListener와 ApplicationEventPublisher만으로 구현된다
- 동기/비동기: 기본적으로는 동기적으로 동작하지만, @Async 어노테이션과 함께 사용하면 비동기적으로 처리할 수 있다.
- 확장성/내결함성: 단일 애플리케이션 인스턴스의 범위 내에서만 유효하며, 분산 환경에서의 확장성이나 내결함성을 제공하지 않는다

 

	카프카 (Kafka)	Spring Simple Broker	Spring Application Events
범위	서버 ↔ 서버 간 통신 (분산 환경)	클라이언트-서버 간 실시간 메시지 전송 (WebSocket/STOMP)	단일 JVM 내부 컴포넌트 간 통신
영속성	메시지 영속성 보장 (디스크 저장)	메시지 비영속성 (인메모리)	메시지 비영속성 (인메모리)
확장성	분산 환경에서 높은 확장성 및 처리량	단일 인스턴스에 한정 (다중 서버 시 External Broker 필요)	단일 애플리케이션 인스턴스 내에서만 유효
내결함성	높음 (클러스터 구성)	낮음 (서버 다운 시 연결 및 메시지 유실)	낮음 (단일 JVM 프로세스에 의존)
복잡성	높음 (외부 클러스터, 설정 필요)	중/낮음 (Spring 내장, WebSocket/STOMP 설정 필요)	낮음 (Spring 내장 기능)
주 용도	이벤트 스트리밍, 마이크로서비스 통신, 데이터 파이프라인	실시간 알림, 웹소켓 채팅, 실시간 데이터 피드 (주식/지도)	애플리케이션 내부 컴포넌트 간 느슨한 결합