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