Package com.hazelcast.jet.cdc
Class DebeziumCdcSources.Builder<T>
java.lang.Object
com.hazelcast.jet.cdc.DebeziumCdcSources.Builder<T>
- Type Parameters:
T
- type of items handled by the source
- Enclosing class:
- DebeziumCdcSources
public static final class DebeziumCdcSources.Builder<T> extends Object
A builder to configure a CDC source that streams the change data from
a Debezium-supported database to Hazelcast Jet.
-
Method Summary
Modifier and Type Method Description StreamSource<T>
build()
Returns the CDC source based on the properties set.DebeziumCdcSources.Builder<T>
setProperty(String key, String value)
Sets a source property.
-
Method Details
-
setProperty
@Nonnull public DebeziumCdcSources.Builder<T> setProperty(@Nonnull String key, @Nonnull String value)Sets a source property. These properties are passed to Debezium. -
build
Returns the CDC source based on the properties set.
-