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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DebeziumCdcSources.Builder<T> 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
static DebeziumCdcSources.Builder<ChangeRecord>	debezium(String name, Class<?> connectorClass) Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<ChangeRecord>	debezium(String name, String connectorClass) Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<Map.Entry<String,String>>	debeziumJson(String name, Class<?> connectorClass) Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
static DebeziumCdcSources.Builder<Map.Entry<String,String>>	debeziumJson(String name, String connectorClass) Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.

Methods inherited from class java.lang.Object

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

Method Detail

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