Class DebeziumCdcSources.Builder<T>

Type Parameters:
T - type of items handled by the source
Enclosing class:

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

      @Nonnull public StreamSource<T> build()
      Returns the CDC source based on the properties set.