Class DebeziumCdcSources.Builder<T>

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

    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 Detail

      • setProperty

        public DebeziumCdcSources.Builder<T> setProperty​(@Nonnull
                                                         java.lang.String key,
                                                         java.lang.String value)
        Sets a source property. These properties are passed to Debezium.
      • build

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