|
Here is an example Qlik delete:
KAFKA-194 only supported the delete information in the beforeData field, looks like the data field should be used if beforeData is null.
{"magic": "atMSG", "type": "DT", "headers": null, "messageSchemaId": null, "messageSchema": null, "message":
|
{"data": {"order_id": 19, "product_name": "test", "product_SKU": "T1", "quantity": 12222}, "beforeData": null,
|
"headers": {"operation": "DELETE", "changeSequence": "20210323144500000000000000000000077", "timestamp": "2021-03-23T14:45:00.000",
|
"streamPosition": "mysql-bin.000004:4998:18:5373:17179874048:mysql-bin.000004:4937", "transactionId": "00000000000000000000000400001300",
|
"changeMask": "01", "columnMask": "0F", "transactionEventCounter": 19, "transactionLastEvent": false}}}
|
|