Uses of Class
com.hazelcast.jet.cdc.DebeziumCdcSources.Builder
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.
|
-
Uses of DebeziumCdcSources.Builder in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc that return DebeziumCdcSources.Builder Modifier and Type Method Description 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, 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.