Contains source/sink connectors that deal with Change Data Capture (CDC) events from various databases as well as a generic connector for Debezium CDC sources.
- Jet 4.2
Interface Summary Interface Description ChangeRecordInformation pertaining to a single data change event (insert, delete or update), affecting a single database record. RecordPartRepresents the top-level component of a
ChangeRecord, such as the key or the value.
Class Summary Class Description CdcSinksContains factory methods for change data capture specific pipeline sinks. DebeziumCdcSourcesContains factory methods for creating Change Data Capture (CDC) sources. DebeziumCdcSources.Builder<T>A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.
Enum Summary Enum Description OperationDescribes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.
Exception Summary Exception Description ParsingExceptionException to indicate that parsing CDC JSON data has failed irrecoverably.