Package com.hazelcast.jet.cdc

Class DebeziumCdcSources

java.lang.Object
com.hazelcast.jet.cdc.DebeziumCdcSources
@EvolvingApi public final class DebeziumCdcSources extends Object
Contains factory methods for creating Change Data Capture (CDC) sources.

Note: It is better to use first-class CDC sources than this generic one because it has less functionality. For example, these sources lack sequence numbers, so functionality based on them (like reordering protection in CdcSinks) is disabled.

Since:
Jet 4.2

  • Method Details

    • debezium

      @Nonnull public static DebeziumCdcSources.Builder<ChangeRecord> debezium(@Nonnull String name, @Nonnull String connectorClass)
      Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
      Parameters:
      name - the name of this source, must unique, will be passed to the underlying Kafka Connect source
      connectorClass - name of the Debezium connector class
      Returns:
      a builder you can use to set the source's properties and then construct it

    • debezium

      @Nonnull public static DebeziumCdcSources.Builder<ChangeRecord> debezium(@Nonnull String name, @Nonnull Class<?> connectorClass)
      Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
      Parameters:
      name - the name of this source, must unique, will be passed to the underlying Kafka Connect source
      connectorClass - class of the Debezium Connector which will be used for the CDC
      Returns:
      a builder you can use to set the source's properties and then construct it

    • debeziumJson

      @Nonnull public static DebeziumCdcSources.Builder<Map.Entry<String,String>> debeziumJson(@Nonnull String name, @Nonnull String connectorClass)
      Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.

      Differs from the regular source in that it does the least possible amount of processing of the raw Debezium data. Just returns a pair of JSON strings, one is the key of the Debezium CDC event, the other the value.

      Parameters:
      name - the name of this source, must unique, will be passed to the underlying Kafka Connect source
      connectorClass - name of the Debezium connector class
      Returns:
      a builder you can use to set the source's properties and then construct it

    • debeziumJson

      @Nonnull public static DebeziumCdcSources.Builder<Map.Entry<String,String>> debeziumJson(@Nonnull String name, @Nonnull Class<?> connectorClass)
      Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.

      Differs from the regular source in that it does the least possible amount of processing of the raw Debezium data. Just returns a pair of JSON strings, one is the key of the Debezium CDC event, the other the value.

      Parameters:
      name - the name of this source, must unique, will be passed to the underlying Kafka Connect source
      connectorClass - class of the Debezium Connector which will be used for the CDC
      Returns:
      a builder you can use to set the source's properties and then construct it