본문으로 건너뛰기

CDC 커넥터

GenD의 CDC(Change Data Capture) 기능은 Debezium Connect를 통해 데이터 소스의 변경 사항을 실시간으로 캡처하고 추적합니다. 데이터베이스의 INSERT, UPDATE, DELETE 이벤트를 자동으로 감지하여 다운스트림 시스템에 전달합니다.

CDC + Kafka 데이터 흐름​

운영 주의: KRaft cluster-id 변경은 greenfield 마이그레이션입니다 — PVC 삭제 + 데이터/offset 손실 동의 필요. 소비자는 UNKNOWN_TOPIC_ID 회피를 위해 metadata refresh 후 재시작해야 합니다 (#640).

CDC 커넥터

주요 기능​

  • Debezium 커넥터 관리: Debezium Connect REST API를 통해 CDC 커넥터를 생성, 조회, 삭제합니다
  • 실시간 변경 캡처: 소스 데이터베이스의 WAL/binlog를 읽어 변경 이벤트를 실시간으로 캡처합니다
  • 커넥터 상태 모니터링: 각 CDC 커넥터의 실행 상태와 오류를 모니터링합니다
  • 커넥터 재시작: 오류 발생 시 커넥터를 수동으로 재시작할 수 있습니다

지원 소스​

  • PostgreSQL (logical replication)
  • MySQL (binlog)
  • SQL Server (CT)
  • MongoDB (change streams)

사용 방법​

  1. ⚙ 관리 콘솔 → 데이터플레인 설정 → CDC 커넥터 메뉴에서 커넥터 추가 버튼을 클릭합니다
  2. 소스 데이터베이스 유형과 연결 정보를 설정합니다
  3. 캡처할 테이블/스키마를 지정합니다
  4. 커넥터를 생성하면 자동으로 변경 캡처가 시작됩니다

API 엔드포인트​

MethodPathDescription
GET/api/v1/cdc/connectorsCDC 커넥터 목록 조회
POST/api/v1/cdc/connectorsCDC 커넥터 생성
GET/api/v1/cdc/connectors/{name}/status커넥터 상태 조회
DELETE/api/v1/cdc/connectors/{name}커넥터 삭제
POST/api/v1/cdc/connectors/{name}/restart커넥터 재시작

관련 문서​