diff --git a/kafka-connect/ref_connector_api_calls/70.toolkit_biometric_scores.api b/kafka-connect/ref_connector_api_calls/70.toolkit_biometric_scores.api index 2eb4671..4f44aa6 100644 --- a/kafka-connect/ref_connector_api_calls/70.toolkit_biometric_scores.api +++ b/kafka-connect/ref_connector_api_calls/70.toolkit_biometric_scores.api @@ -36,7 +36,13 @@ curl \ "behavior.on.null.values": "DELETE", - "transforms": "ext1,ext2,tsconvert01,stringtojson01,tsSelect", + "transforms": "debezExtract,ext1,ext2,tsconvert01,stringtojson01,tsSelect", + + "transforms.debezExtract.type": "io.debezium.transforms.ExtractNewRecordState", + "transforms.debezExtract.delete.handling.mode": "drop", + "transforms.debezExtract.drop.tombstones": "false", + "transforms.debezExtract.add.fields": "source.ts_ms:ts_ms,table,lsn", + "transforms.debezExtract.add.fields.prefix": "source_", "transforms.ext1.type": "org.apache.kafka.connect.transforms.ExtractField$Value", "transforms.ext1.field": "payload",