오픈소스/kafka

Debezium insert mode

pastime 2024. 3. 9. 00:14
728x90

CDC 의 설정 방법은 여러가지가 있지만 그중 insert.mode 세팅 관련

 

 

insert.mode 에는 2가지 설정값이 있다
1. (default) insert
2. upsert

관련 문서 : https://debezium.io/documentation/reference/stable/connectors/jdbc.html#jdbc-idempotent-writes

 

CDC를 할떄 보통 이기종간의 데이터를 한곳(DW)에서 보기위해 작업을 진행하는데

목적에 맞게 insert.mode를 설정하면 될것같다.

 

해당 테이블의 히스토리를 보고싶다 : insert

최신 데이터를 보고싶다 : upsert

 

두 설정값의 차이는

ㅁ upsert

"pk.mode": "record_key",
"delete.enabled": "true",
"insert.mode": "upsert",

 

ㅁ insert

"insert.mode": "insert",

 

728x90