[DebeziumTransform] Allow _cdc.ts to be derived from source.ts_ms rather than <root>.ts_ms.

tabular-io / iceberg-kafka-connect

Apache License 2.0

171 stars 31 forks source link

[DebeziumTransform] Allow _cdc.ts to be derived from source.ts_ms rather than <root>.ts_ms. #189

Open megri opened 5 months ago

megri commented 5 months ago

We are relying on the nested field source.ts_ms to track creation/update times where the source table doesn't have or misuses corresponding columns. It would be great if the SMT could be configured to support this, or better yet if both timestamps were kept around.