Key value needs to be included in all Kafka messages produced by SharePlex.
SharePlex will produce the key value in updates only.
This is by design in SharePlex, on the basis that all column values are produced in Inserts and Deletes.
In the example below, Insert, Update and Delete all produced to Kafka by SharePlex.
The 'key' value in the Update record is highlighted in bold
{"meta":{"op":"ins","table":"PHUNT1013U1.ROCK_BAND"},"data":{"BAND_NAME":"Rush","YEAR_START":1974,"SORTED":"2024-05-24T15:58:48.000000000"} }
{"meta":{"op":"upd","table":"PHUNT1013U1.ROCK_BAND"},"data":{"YEAR_END":2015},"key":{"BAND_NAME":"Rush"} }
{"meta":{"op":"del","table":"PHUNT1013U1.ROCK_BAND"},"data":{"BAND_NAME":"Rush","YEAR_START":1974,"YEAR_END":2015,"SORTED":"2024-05-24T15:58:48.000000000"} }
In the above example, the table name is ROCK_BAND and it has a unique index based upon the BAND_NAME column.
