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.
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.