Package org.springframework.integration.debezium.dsl

Class Debezium

java.lang.Object

org.springframework.integration.debezium.dsl.Debezium

public final class Debezium
extends Object

Factory class for Debezium DSL components.

Since:

6.2

Author:

Christian Tzolov, Artem Bilan

Method Summary

Modifier and Type	Method	Description
static DebeziumMessageProducerSpec	inboundChannelAdapter(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)	Create an instance of DebeziumMessageProducerSpec for the provided DebeziumEngine.Builder.
static DebeziumMessageProducerSpec	inboundChannelAdapter(Properties debeziumConfig)	Create an instance of DebeziumMessageProducerSpec for the provided native debezium Properties and JSON serialization formats.
static DebeziumMessageProducerSpec	inboundChannelAdapter(Properties debeziumConfig, Class<? extends io.debezium.engine.format.SerializationFormat<byte[]>> messageFormat, Class<? extends io.debezium.engine.format.SerializationFormat<byte[]>> headerFormat)	Create an instance of DebeziumMessageProducerSpec for the provided native debezium Properties and serialization formats.

Methods inherited from class java.lang.Object

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

Method Details

inboundChannelAdapter

public static DebeziumMessageProducerSpec inboundChannelAdapter(Properties debeziumConfig)

Create an instance of DebeziumMessageProducerSpec for the provided native debezium Properties and JSON serialization formats.

Parameters:

debeziumConfig - Properties with required debezium engine and connector properties.

Returns:

the spec.

inboundChannelAdapter

public static DebeziumMessageProducerSpec inboundChannelAdapter(Properties debeziumConfig,
 Class<? extends io.debezium.engine.format.SerializationFormat<byte[]>> messageFormat,
 Class<? extends io.debezium.engine.format.SerializationFormat<byte[]>> headerFormat)

Create an instance of DebeziumMessageProducerSpec for the provided native debezium Properties and serialization formats.

Parameters:

debeziumConfig - Properties with required debezium engine and connector properties.

messageFormat - SerializationFormat format for the ChangeEvent key and payload.

headerFormat - SerializationFormat format for the ChangeEvent headers.

Returns:

the spec.

inboundChannelAdapter

public static DebeziumMessageProducerSpec inboundChannelAdapter(io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)

Create an instance of DebeziumMessageProducerSpec for the provided DebeziumEngine.Builder.

Parameters:

debeziumEngineBuilder - the DebeziumEngine.Builder to use.

Returns:

the spec.