Package com.hazelcast.jet.cdc
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.
- Since:
- Jet 4.2
-
Interface Summary Interface Description ChangeRecord Information pertaining to a single data change event (insert, delete or update), affecting a single database record.RecordPart Represents the top-level component of aChangeRecord
, such as the key or the value. -
Class Summary Class Description CdcSinks Contains factory methods for change data capture specific pipeline sinks.DebeziumCdcSources Contains 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 Operation Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion. -
Exception Summary Exception Description ParsingException Exception to indicate that parsing CDC JSON data has failed irrecoverably.