Package com.hazelcast.jet.cdc
Class DebeziumCdcSources
java.lang.Object
com.hazelcast.jet.cdc.DebeziumCdcSources
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
Modifier and TypeClassDescriptionstatic final class
A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet. -
Method Summary
Modifier and TypeMethodDescriptionCreates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.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.
-
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 sourceconnectorClass
- 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 sourceconnectorClass
- 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 sourceconnectorClass
- 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 sourceconnectorClass
- 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
-