Avro-formatted data in Kafka
Oracle CDC events formatted as Avro and written to Kafka will be similar to the following examples. For more information, see OracleReader WAEvent fields.
SQL*Plus command insert into qatest.vtesttable values(1,'insert1');
{ "metadata": { "TxnID": "9.5.256818", "RbaSqn": "65036", "TableSpace": "USERS", "CURRENTSCN": "402873649", "OperationName": "INSERT", "ParentTxnID": "9.5.256818", "SegmentType": "TABLE", "SessionInfo": "UNKNOWN", "TxnUserID": "UNKNOWN", "Session": "72", "BytesProcessed": "593", "TransactionName": "", "STARTSCN": "402873649", "SegmentName": "VTESTTABLE", "SEQUENCE": "1", "COMMITSCN": "402873650", "RbaBlk": "20376", "ThreadID": "1", "SCN": "40287364900183060065866895851680000", "AuditSessionId": "2064718", "ROWID": "AAJb5rAAEAAATL8AAA", "TimeStamp": "2017-02-02T04:48:18.000-08:00", "Serial": "36570", "RecordSetID": " 0x00fe0c.00004f98.0010 ", "TableName": "QATEST.VTESTTABLE", "OperationType": "DML", "SQLRedoLength": "69", "Rollback": "0" }, "before": null, "data": { "ID": "1", "NAME": "insert1" } }
SQL*Plus command UPDATE qatest.vtesttable SET NAME='Vino' WHERE ID=10;
:
{ "metadata": { "TxnID": "6.18.239971", "RbaSqn": "65036", "TableSpace": "USERS", "CURRENTSCN": "402878537", "OperationName": "UPDATE", "ParentTxnID": "6.18.239971", "SegmentType": "TABLE", "SessionInfo": "UNKNOWN", "TxnUserID": "UNKNOWN", "Session": "72", "BytesProcessed": "635", "TransactionName": "", "STARTSCN": "402878537", "SegmentName": "VTESTTABLE", "SEQUENCE": "1", "COMMITSCN": "402878538", "RbaBlk": "38226", "ThreadID": "1", "SCN": "40287853700183060065878594027680000", "AuditSessionId": "2064718", "ROWID": "AAJb5rAAEAAATL8AAJ", "TimeStamp": "2017-02-02T05:20:54.000-08:00", "Serial": "36570", "RecordSetID": " 0x00fe0c.00009552.0010 ", "TableName": "QATEST.VTESTTABLE", "OperationType": "DML", "SQLRedoLength": "90", "Rollback": "0" }, "before": { "ID": "10", "NAME": "insert10" }, "data": { "ID": "10", "NAME": "Vino" } }