변경 기록에서 사건으로
데이터베이스별 커넥터가 원천에 연결해 변경 내용을 읽는다. MySQL에서는 binlog를 사용하고 PostgreSQL에서는 논리 복제 스트림을 읽는다. 변경 결과를 사건으로 표현해 이후 처리로 보낸다.
Kafka를 경유하는 처리 경로
Kafka Connect에 원천 커넥터로 배치하면 변경 기록을 Kafka 토픽으로 전달한다. 다른 출력 커넥터가 이를 읽어 검색 저장소와 분석 저장소 및 캐시 같은 목적지로 보낼 수 있다. 토픽 라우팅 설정으로 테이블과 토픽의 대응을 조정한다.
다른 실행 방식의 선택
Debezium Server는 변경 사건을 여러 메시징 시스템으로 보내는 독립 응용이다. Engine은 Java 응용에 포함하는 라이브러리 형태다. 변경을 수집하는 기능과 그 결과를 처리할 실행 환경을 나누어 선택할 수 있다.
관련 문서
Apache Kafka / PostgreSQL / MySQL / Apache Pulsar / Apache Avro / CloudEvents