All Classes and Interfaces

Class	Description
CdcSinks	Contains factory methods for change data capture specific pipeline sinks.
ChangeRecord	Information pertaining to a single data change event (insert, delete or update), affecting a single database record.
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.
DebeziumSnapshotMode	Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.
Operation	Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.
ParsingException	Exception to indicate that parsing CDC JSON data has failed irrecoverably.
RecordMappingFunction<R>	Function that maps given SourceRecord to some particular R type.
RecordPart	Represents the top-level component of a ChangeRecord, such as the key or the value.
SequenceExtractor	Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering of ChangeRecord items.