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:
- 4.2
-
Nested Class Summary
Nested Classes Modifier and Type Class 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 Description 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, String connectorClass)
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
-
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- 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.- Returns:
- a builder you can use to set the source's properties and then construct it
-