Uses of Class
org.springframework.integration.debezium.dsl.DebeziumMessageProducerSpec

Packages that use DebeziumMessageProducerSpec

Package	Description
org.springframework.integration.debezium.dsl	Provides classes for supporting Debezium component via Java DSL.

Uses of DebeziumMessageProducerSpec in org.springframework.integration.debezium.dsl

Subclasses with type arguments of type DebeziumMessageProducerSpec in org.springframework.integration.debezium.dsl

Modifier and Type	Class	Description
class	DebeziumMessageProducerSpec	A MessageProducerSpec for DebeziumMessageProducer.

Methods in org.springframework.integration.debezium.dsl that return DebeziumMessageProducerSpec

Modifier and Type	Method	Description
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.contentType(String contentType)	Set the outbound message content type.
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.enableBatch(boolean enable)	Enable the ChangeEvent batch mode handling.
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.enableEmptyPayload(boolean enabled)	Enable support for tombstone (aka delete) messages.
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.headerMapper(HeaderMapper<List<io.debezium.engine.Header<Object>>> headerMapper)	Set a HeaderMapper to convert the ChangeEvent headers into Message headers.
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.headerNames(String... headerNames)	Comma-separated list of names of ChangeEvent headers to be mapped into outbound Message headers.
static DebeziumMessageProducerSpec	Debezium.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	Debezium.inboundChannelAdapter(Properties debeziumConfig)	Create an instance of DebeziumMessageProducerSpec for the provided native debezium Properties and JSON serialization formats.
static DebeziumMessageProducerSpec	Debezium.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.
DebeziumMessageProducerSpec	DebeziumMessageProducerSpec.taskExecutor(TaskExecutor taskExecutor)	Set a TaskExecutor for the Debezium engine.