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 © 2022 Hazelcast, Inc.. All rights reserved.