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 and 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

setProperty

@Nonnull
public DebeziumCdcSources.Builder<T> setProperty(@Nonnull
                                                          String key,
                                                          @Nonnull
                                                          String value)

Sets a source property. These properties are passed to Debezium.

build

@Nonnull
public StreamSource<T> build()

Returns the CDC source based on the properties set.