Uses of Package
com.hazelcast.enterprise.jet.cdc
Package
Description
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.
MySQL-specific CDC API.
PostgreSQL-specific CDC API.
-
ClassDescriptionInformation pertaining to a single data change event (insert, delete or update), affecting a single database record.A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.Exception to indicate that parsing CDC JSON data has failed irrecoverably.Function that maps given
SourceRecord
to some particularR
type.Represents the top-level component of aChangeRecord
, such as the key or the value.Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering ofChangeRecord
items. -
ClassDescriptionInformation pertaining to a single data change event (insert, delete or update), affecting a single database record.A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.Function that maps given
SourceRecord
to some particularR
type.Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering ofChangeRecord
items. -
ClassDescriptionInformation pertaining to a single data change event (insert, delete or update), affecting a single database record.A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.Function that maps given
SourceRecord
to some particularR
type.Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering ofChangeRecord
items.