Add record key to Debezium CDC metadata

tabular-io / iceberg-kafka-connect

Apache License 2.0

192 stars 41 forks source link

Add record key to Debezium CDC metadata #107

Closed bryanck closed 11 months ago

bryanck commented 11 months ago

This PR adds the record key to the CDC metadata in the Debezium SMT. The record key in Debezium is the primary key by default, so this can be used for merges/deltas.