116
이벤트 기반 마이크로서비스 구축
4.8
이벤트 데이터를 데이터 저장소에 싱킹
이벤트 스트림 데이터는 이벤트 데이터를 소비해서 데이터 저장소에 삽입하는 싱킹을 수행합
니다. 일반적으로 싱킹은 중앙화 프레임워크나 단독형 마이크로서비스를 이용해서 수행하며
엔티티, 키 있는 이벤트, 키 없는 이벤트 등 어떤 유형의 이벤트 데이터라도 데이터 저장소에
저장할 수 있습니다.
이벤트 싱킹은 이벤트 기반으로 개발되지 않은 애플리케이션을 이벤트 스트림과 통합할 때 특
히 유용합니다. 싱크 프로세스는 이벤트 브로커에서 이벤트 스트림을 읽어들여 지정된 데이터
저장소에 데이터를 삽입합니다. 또 이벤트 기반이 아닌 애플리케이션과 완벽하게 독립적으로
작동되면서 자신의 소비 오프셋을 추적하고 이벤트 데이터가 도착하는 대로 데이터 저장소에
씁니다.
이벤트 싱킹은 주로 레거시 시스템 간의 직접적인 점대점 결합을 대체하는 용도로 쓰입니다.
소스 시스템의 데이터를 일단 이벤트 스트림으로 해방하면 별다른 변경 없이도 목적지 시스템
에 싱크할 수 있죠. 싱크 프로세스는 목적지 시스템에 대해 외부적으로 투명하게 작동됩니다.
데이터 싱킹은 배치 기반의 빅데이터 분석을 수행하는 팀에서도 자주 활용됩니다. 빅데이터 분
석자들은 보통 분석 도구를 제공하는 하둡 분산 파일 시스템
Hadoop
Distributed
File
System
(
HDFS
)에
데이터를 싱크합니다.
카프카 커넥트 같은 공통 플랫폼을 사용하면 간단한 설정만으로 싱크 프로세스를 구성해서 공
유 인프라에 올려놓고 실행할 ...