| Package | Description | 
|---|---|
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static DebeziumCdcSources.Builder<ChangeRecord> | 
DebeziumCdcSources.debezium(String name,
        Class<?> connectorClass)
Creates a CDC source that streams change data from a
 Debezium-supported database to a Hazelcast Jet pipeline. 
 | 
static DebeziumCdcSources.Builder<ChangeRecord> | 
DebeziumCdcSources.debezium(String name,
        String connectorClass)
Creates a CDC source that streams change data from a
 Debezium-supported database to a Hazelcast Jet pipeline. 
 | 
static DebeziumCdcSources.Builder<Map.Entry<String,String>> | 
DebeziumCdcSources.debeziumJson(String name,
            Class<?> connectorClass)
Creates a CDC source that streams change data from a
 Debezium-supported database to a Hazelcast Jet pipeline. 
 | 
static DebeziumCdcSources.Builder<Map.Entry<String,String>> | 
DebeziumCdcSources.debeziumJson(String name,
            String connectorClass)
Creates a CDC source that streams change data from a
 Debezium-supported database to a Hazelcast Jet pipeline. 
 | 
DebeziumCdcSources.Builder<T> | 
DebeziumCdcSources.Builder.setProperty(String key,
           String value)
Sets a source property. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.