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 a ChangeRecord, 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.