MOSIP-27967 updated biometric scores connector (#75)

Signed-off-by: Mayura Deshmukh <[email protected]>
mosip · Oct 11, 2023 · 29b22c9 · 29b22c9
1 parent 2558a0e
commit 29b22c9
Showing 1 changed file with 14 additions and 12 deletions.
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,26 +36,28 @@ curl \
 
           "behavior.on.null.values": "DELETE",
 
-          "transforms": "debezExtract,tsconvert01,stringtojson01,tsconvert02,tsSelect",
+          "transforms": "extValue1,extValue2,extKey1,extKey2,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.extValue1.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
+          "transforms.extValue1.field": "payload",
+          "transforms.extValue2.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
+          "transforms.extValue2.field": "after",
+
+          "transforms.extKey1.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
+          "transforms.extKey1.field": "payload",
+          "transforms.extKey2.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
+          "transforms.extKey2.field": "id",
 
           "transforms.tsconvert01.type": "io.mosip.kafka.connect.transforms.TimestampConverterAdv$Value",
-          "transforms.tsconvert01.field": "source_ts_ms",
+          "transforms.tsconvert01.field": "cr_dtimes",
+          "transforms.tsconvert01.input.type": "micro_sec",
 
           "transforms.stringtojson01.type": "io.mosip.kafka.connect.transforms.StringToJson$Value",
           "transforms.stringtojson01.input.field": "scores_json",
-
-          "transforms.tsconvert02.type": "io.mosip.kafka.connect.transforms.TimestampConverterAdv$Value",
-          "transforms.tsconvert02.field": "cr_dtimes",
-          "transforms.tsconvert02.input.type": "micro_sec",
-
+
           "transforms.tsSelect.type": "io.mosip.kafka.connect.transforms.TimestampSelector$Value",
           "transforms.tsSelect.ts.order": "cr_dtimes",
           "transforms.tsSelect.output.field": "@timestamp_gen"
+
       }
 }';