brimdata / zync

Kafka connector to sync Zed lakes to and from Kafka topics
BSD 3-Clause "New" or "Revised" License
18 stars 3 forks source link

adjust ETL for JDBC sync connector records #51

Closed nwt closed 2 years ago

nwt commented 2 years ago

ETL transforms need access to Debezium event keys to produce valid JDBC sync connector records. Give them access to the entire event as this.left and this.right for denorm transforms and as this.in for stateless transforms, and change the output field to this.out for consistency.