I have a simple workflow where in the source is kafka topic and target is flat file. it is a one-one mapping. I have imported the kafka topic and created mapping as follows.
I have imported the Kafka Topic using powerexchange for Kafka source in source analyzer. I have created a json file with all the fields and used for importing the kafka source. I am wondering if my source imported is in correct format like the fields as job is succeeded but could not pick any message.
sample topic message::
`{
"metadata": {
"correlationId": "3452658399_20231011063145338354-232",
"eventType": "FTAEventPublisher",
"processDateTimeUTC": "2023-10-12T12:56:26.1441781Z",
"eventID": "a0ec992a-cf7c-4d86-bb84-428055bb2506",
"keyIdentifiers": {
"AccountID": "34526589",
"Identifier": "NONCHMA"
}
},
"data": {
"accountId": 34526589,
"salesrep": {
"referenceData": {
"name": "V, SUMAN",
"email": null,
"roleName": " Data Protection Solutions Sales Engineer",
"NT_login": null
},
"badgeID": 580112,
"primaryAssignee": "N",
"roleID": 21966,
"regionalStartDate": "1/29/2022 12:48:38 PM",
"regionalEndDate": null,
"accountOwner": "Y",
"status": "A"
}
}
}
Session logs click here to download
json schema file used to import in informatica for source definition based on schema
I have executed the workflow to read message from kafka source however the workflow will run and succeeded there is no source data being read and processed to target. I am working on kafka for the first time. Kindly look into the mapping and source schema if i have done it right.