From dec06cbbde3cfe1c731bfa17463376ceb59674a3 Mon Sep 17 00:00:00 2001 From: Mayura Deshmukh Date: Thu, 26 Oct 2023 16:12:00 +0530 Subject: [PATCH] MOSIP-29932 fixing auto update issue Signed-off-by: Mayura Deshmukh --- .../70.toolkit_biometric_scores.api | 15 ++++++--------- .../71.toolkit_biometric_scores_new.api | 9 ++++++--- 2 files changed, 12 insertions(+), 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 index 4f44aa6..d161454 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,13 +36,7 @@ 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", @@ -50,8 +44,11 @@ curl \ "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 index 234c362..6db9f5e 100644 --- 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",