Sample Event

{
  "_io": {
    "db": {
      "database": "kafka",
      "databaseProductName": "MySQL",
      "databaseProductVersion": "5.7.24",
      "schema": "kafka",
      "tableName": "IO_DATASOURCE"
    },
    "eventAction": "Insert",
    "eventName": "",
    "eventType": "IO_DATASOURCE",
    "flowCode": "io-datasource",
    "flowUuid": "2Wm2EJyS3UWKlbvubs75WG",
    "inputType": "MySQL",
    "mappedDateTime": "2020-01-10T20:38:03.189000Z",
    "mapperCount": 1,
    "messageUid": "u58yTR0NbN7c5rzafNp5l",
    "outputCount": 1,
    "postedDateTime": "2020-01-10T20:38:04.222000Z",
    "receivedDateTime": "2020-01-10T20:37:52.827000Z",
    "runId": 1,
    "topic": "io-transformed",
    "transformCount": 1,
    "uuid": "u58yTR0NbN7c5rzafNp5l"
  },
  "data": {
    "ACTIVE_1": "Y",
    "LAST_UPDATE_DATE": "2019-11-24T08:56:55.246000Z",
    "CONNECTION_CODE": "$cloudio",
    "CREATED_BY": "xxapps",
    "TABLE_NAME_1": "IO_FLOW_RUNS",
    "LAST_UPDATED_BY": "xxapps",
    "LAST_UPDATED_SID": "1tGXihPYkeg43Ic0ozobAf",
    "CREATION_DATE": "2019-11-24T08:56:55.246000Z",
    "USE_API": "N",
    "ORG_UID": "cloudio",
    "DATASOURCE_NAME": "IoFlowRuns",
    "FULL_DATASOURCE_NAME": "Io Flow Runs",
    "DATASOURCE_UID": "IoFlowRuns"
  },
  "originalMessage": {
    "DATASOURCE_UID": "IoFlowRuns",
    "DATASOURCE_NAME": "IoFlowRuns",
    "ACTIVE": "Y",
    "USE_API": "N",
    "TABLE_NAME": "IO_FLOW_RUNS",
    "FULL_DATASOURCE_NAME": "Io Flow Runs",
    "ORG_UID": "cloudio",
    "CREATION_DATE": "2019-11-24T08:56:55.246000Z",
    "CREATED_BY": "xxapps",
    "LAST_UPDATE_DATE": "2019-11-24T08:56:55.246000Z",
    "LAST_UPDATED_BY": "xxapps",
    "LAST_UPDATED_SID": "1tGXihPYkeg43Ic0ozobAf",
    "CONNECTION_CODE": "$cloudio"
  }
}