Striim 3.9.4 / 3.9.5 documentation

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"
        }
}