MOSIP-29932 fixing auto update issue (#81)

Signed-off-by: Mayura Deshmukh <[email protected]>
mosip · Oct 26, 2023 · f492c0f · f492c0f
1 parent 32f507f
commit f492c0f
Show file tree

Hide file tree

Showing 2 changed files with 12 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,22 +36,19 @@ curl \
 
           "behavior.on.null.values": "DELETE",
 
-          "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,ext2,tsconvert01,tsconvert02,stringtojson01,tsSelect",
 
           "transforms.ext1.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
           "transforms.ext1.field": "payload",
           "transforms.ext2.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
           "transforms.ext2.field": "after",
 
           "transforms.tsconvert01.type": "io.mosip.kafka.connect.transforms.TimestampConverterAdv$Value",
-          "transforms.tsconvert01.field": "cr_dtimes",
-          "transforms.tsconvert01.input.type": "micro_sec",
+          "transforms.tsconvert01.field": "source_ts_ms"
+
+          "transforms.tsconvert02.type": "io.mosip.kafka.connect.transforms.TimestampConverterAdv$Value",
+          "transforms.tsconvert02.field": "cr_dtimes",
+          "transforms.tsconvert02.input.type": "micro_sec",
 
           "transforms.stringtojson01.type": "io.mosip.kafka.connect.transforms.StringToJson$Value",
           "transforms.stringtojson01.input.field": "scores_json",

diff --git a/kafka-connect/ref_connector_api_calls/71.toolkit_biometric_scores_new.api b/kafka-connect/ref_connector_api_calls/71.toolkit_biometric_scores_new.api
@@ -36,7 +36,7 @@ curl \
 
           "behavior.on.null.values": "DELETE",
 
-          "transforms": "debezExtract,tsconvert01,tsSelect",
+          "transforms": "debezExtract,tsconvert01,tsconvert02,tsSelect",
 
           "transforms.debezExtract.type": "io.debezium.transforms.ExtractNewRecordState",
           "transforms.debezExtract.delete.handling.mode": "drop",
@@ -45,8 +45,11 @@ curl \
           "transforms.debezExtract.add.fields.prefix": "source_",
 
           "transforms.tsconvert01.type": "io.mosip.kafka.connect.transforms.TimestampConverterAdv$Value",
-          "transforms.tsconvert01.field": "cr_dtimes",
-          "transforms.tsconvert01.input.type": "micro_sec",
+          "transforms.tsconvert01.field": "source_ts_ms"
+
+          "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",