아카이브사이트맵
© 2026 Rayon. All rights reserved.
DevDay
아티클랭킹스페이스채용
네이버 D2 favicon네이버 D2

네이버페이, Flink 기반 CDC 시스템으로 연간 수십조 데이터 무중단 처리!

by DD
2025-11-18
8개월 전
조회수 25

네이버페이의 DB CDC 복제 도구인 ergate 프로젝트를 소개하며, Apache Flink와 Spring Framework를 활용함

Flink 기반의 CDC 복제 시스템을 구축하여 1초 내 복제 보장 및 성능 10배 향상을 달성함

무중단/무장애 교체를 위해 중복 복제 전략과 자동 복구 기능을 구현하여 안정성을 확보함

Flink 기반 CDC 시스템 아키텍처

nBase-cdc가 MySQL binlog를 읽어 Kafka로 발행하면, ergate의 Flink job이 이를 소비하여 Target DB에 반영한다. 구체적으로, JDBC Sink를 확장하여 DynamicBatchSize를 구현, I/O 병목을 해결했다. 따라서 1초 내 복제 보장 및 을 확보했다.

고가용성

무중단/무장애 전환 전략

ergate와 mig-data의 중복 복제를 통해 무중단 전환을 달성했다. 자동 복구 기능을 구현하여 장애 발생 시에도 데이터 유실을 방지했다. DDL 실행 순서 의존성 제거를 위해 칼럼 캐싱 전략을 사용, 스키마 변경에 유연하게 대응했다.

성능 최적화 및 트러블슈팅

성능 개선을 위해 객체 직렬화 최적화, 데이터 스큐 분산, Flink JdbcSink 확장을 수행했다. AsyncDataStream을 활용하여 검증 성능을 향상시켰다. 결과적으로, 기존 대비 10배 이상 QPS 처리가 가능해졌으며, 레이턴시 감소를 달성했다.

6개월 만에 연간 수십조를 처리하는 DB CDC 복제 도구 무중단/무장애 교체하기
고급
아키텍처
Apache Flink
Spring Framework
Kotlin
Kafka
MySQL
Java
SQL
Backend
Data
원문 읽기
원문 읽기

댓글 0

첫 번째 댓글을 남겨보세요!

관련 추천 글

멱등성, Kafka, Spring Batch 기반 정산 시스템 구축 노하우 공개

무신사 로고

백엔드 개발, 이제 시스템의 깊이를 파고들다!

레딧 로고

Java Kotlin 전환, 성공적인 백엔드 리팩토링 사례

우아한형제들 로고

Java 개발자가 말하는 Kotlin, 왜 써야 할까?

올리브영 로고

Spring Framework 7 릴리즈! Juergen Hoeller 인터뷰

스프링 로고

Kafka 운영은 이제 그만! EasyQueue로 비즈니스 로직에 집중하세요.

NHN클라우드 로고
네이버 D2 favicon네이버 D2
고급
아키텍처
Apache Flink
Spring Framework
Kotlin
Kafka
MySQL
Java
SQL
Backend
Data

관련 추천 글

멱등성, Kafka, Spring Batch 기반 정산 시스템 구축 노하우 공개

무신사 로고

백엔드 개발, 이제 시스템의 깊이를 파고들다!

레딧 로고

Java Kotlin 전환, 성공적인 백엔드 리팩토링 사례

우아한형제들 로고