Package org.springframework.cloud.fn.supplier.debezium

Class DebeziumReactiveConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.debezium.DebeziumReactiveConsumerConfiguration

All Implemented Interfaces:

Aware, BeanClassLoaderAware

@AutoConfiguration(after=org.springframework.cloud.fn.common.debezium.DebeziumEngineBuilderAutoConfiguration.class)
@EnableConfigurationProperties(DebeziumSupplierProperties.class)
@ConditionalOnBean(io.debezium.engine.DebeziumEngine.Builder.class)
public class DebeziumReactiveConsumerConfiguration
extends Object
implements BeanClassLoaderAware

Author:

Christian Tzolov, Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL	ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL.

Constructor Summary

Constructors

Constructor	Description
DebeziumReactiveConsumerConfiguration()

Method Summary

Modifier and Type	Method	Description
Consumer<io.debezium.engine.ChangeEvent<byte[],byte[]>>	changeEventConsumer(org.springframework.cloud.fn.common.debezium.DebeziumProperties engineProperties, DebeziumSupplierProperties supplierProperties)
io.debezium.engine.DebeziumEngine<io.debezium.engine.ChangeEvent<byte[],byte[]>>	debeziumEngine(Consumer<io.debezium.engine.ChangeEvent<byte[],byte[]>> changeEventConsumer, io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)
Supplier<reactor.core.publisher.Flux<Message<?>>>	debeziumSupplier(io.debezium.engine.DebeziumEngine<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngine)
void	setBeanClassLoader(ClassLoader classLoader)

Methods inherited from class java.lang.Object

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

Field Details

ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL

public static final String ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL

ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL.

See Also:

• Constant Field Values

Constructor Details

DebeziumReactiveConsumerConfiguration

public DebeziumReactiveConsumerConfiguration()

Method Details

setBeanClassLoader

public void setBeanClassLoader(ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface BeanClassLoaderAware

debeziumEngine

@Bean
public io.debezium.engine.DebeziumEngine<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngine(Consumer<io.debezium.engine.ChangeEvent<byte[],byte[]>> changeEventConsumer,
 io.debezium.engine.DebeziumEngine.Builder<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngineBuilder)

debeziumSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<Message<?>>> debeziumSupplier(io.debezium.engine.DebeziumEngine<io.debezium.engine.ChangeEvent<byte[],byte[]>> debeziumEngine)

changeEventConsumer

@Bean
@ConditionalOnMissingBean
public Consumer<io.debezium.engine.ChangeEvent<byte[],byte[]>> changeEventConsumer(org.springframework.cloud.fn.common.debezium.DebeziumProperties engineProperties,
 DebeziumSupplierProperties supplierProperties)