Hi -
Currently we have Goldengate sending messages to kafka, and then the message is formatted.
So wanted to check if we can format the message with Goldengate while its sendng to kafka.
Cuurently we are seeing kafka message like this:
{
"table": "TEST.TABLE",
"op_type": "U",
"op_ts": "2018-02-02 20:17:18.000000",
"current_ts": "2018-02-02T15:17:22.124000",
"pos": "00000000050000123456",
"before": {
"SEQ_ID": 36191,
"BEN_ID": "123456789",
"BAD_ID": "987654321",
"STS_CD": "A",
"STS_CD_OTHER": "Y",
"PS_CRE_TS": "2017-11-13 12:23:00",
"PS_CRE_BY_USR_ID": "z123z456",
"STG_LST_APR_BY_USR_ID": null,
"STG_LST_APR_TS": null,
"STG_LST_MOD_BY_USR_ID": null,
"STG_LST_MOD_TS": null,
"TRIG_INS_UPD_DATE": "2017-11-13 12:32:16.711929000"
},
"after": {
"SEQ_ID": 36191,
"BEN_ID": "123456789",
"BAD_ID": "987654321",
"STS_CD": "I",
"STS_CD_OTHER": "Y",
"PS_CRE_TS": "2017-11-13 12:23:00",
"PS_CRE_BY_USR_ID": "z123z456",
"STG_LST_APR_BY_USR_ID": "z456z123",
"STG_LST_APR_TS": "2018-02-02 15:17:18",
"STG_LST_MOD_BY_USR_ID": "x789z456",
"STG_LST_MOD_TS": "2018-02-02 15:06:48",
"TRIG_INS_UPD_DATE": "2018-02-02 15:17:18.504636000"
}
}
But we want Goldengate to send message to kafka like below:
{
"operation": "U",
"source": "DF",
"BenId": "123456789",
"badId": "987654321",
"badStatus": "I",
"prevBenId": "123456789",
"prevBadId": "987654321",
"creUserId": "z123z456",
"creTimeStamp": "2017-11-13 12:23:00",
"aprUserId": "z456z123",
"aprTimeStamp": "2018-02-02 15:17:18",
"modUserId": "x789z456",
"modTimeStamp": "2018-02-02 15:06:48"
}
So, can anyone please help how can we map the columns for before and after values. Thanks!!