CDC (Change Data Capture) helps you identify data that has changed since the last extraction. You can use CDC data for historical databases, near-real-time caches, message queues (MQ), and for analysis and auditing when consuming MQ.
obcdc (OceanBase Change Data Capture, the OceanBase log parsing component) provides real-time incremental (transaction) data from OceanBase Database in the form of a dynamic library.
obcdc requests clog (Redo) logs from each partition of OceanBase Database through RPC, combines schema information of tables and columns (obtained through SQL interaction with OBServer nodes), converts Redo logs into an intermediate data format (LOGMSG), aggregates data changes across partitions involved in a transaction, and outputs change data row by row on a per-transaction basis.
Applications of obcdc
obcdc provides incremental transaction data from OceanBase Database. Processes that invoke obcdc can use the data for data synchronization and data subscription.
Data synchronization: Synchronize OceanBase data to homogeneous or heterogeneous databases for logical migration, logical standby, logical upgrade, and more.
Data subscription: Synchronize OceanBase data to message queues or data warehouses for real-time computing, auditing, monitoring, and more.
For detailed instructions on how to use obcdc, see obcdc development instructions.