Uses of Class
com.hazelcast.jet.cdc.DebeziumCdcSources.Builder
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.
-
Uses of DebeziumCdcSources.Builder in com.hazelcast.jet.cdc
Modifier and TypeMethodDescriptionCreates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.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.setProperty
(String key, String value) Sets a source property.