MOSIP-27967 trying to fix autoupdate issue (#78)

Signed-off-by: Mayura Deshmukh <[email protected]>
mosip · Oct 18, 2023 · 7bf1146 · 7bf1146
1 parent 5251120
commit 7bf1146
Showing 1 changed file with 7 additions and 1 deletion.
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
@@ -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",