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 java.lang.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(java.lang.String key, java.lang.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
                                                 java.lang.String key,
                                                 @Nonnull
                                                 java.lang.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.