org.springframework.cloud.fn.supplier.cdc

Class CdcSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.cdc.CdcSupplierConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware

@EnableConfigurationProperties(value=CdcSupplierProperties.class)
 @Import(value=CdcCommonConfiguration.class)
public class CdcSupplierConfiguration
extends Object
implements org.springframework.beans.factory.BeanClassLoaderAware

CDC source that uses the Debezium Connectors to monitor and record all of the row-level changes in the databases. https://debezium.io/docs/connectors

Author:

Christian Tzolov

Field Summary

Fields

Modifier and Type	Field and Description
static String	ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL ORG_SPRINGFRAMEWORK_KAFKA_SUPPORT_KAFKA_NULL.

Constructor Summary

Constructors

Constructor and Description
CdcSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	cdcSupplier(EmbeddedEngineExecutorService embeddedEngineExecutorService)
EmbeddedEngineExecutorService	embeddedEngineExecutorService(EmbeddedEngine.Builder embeddedEngineBuilder, Function<org.apache.kafka.connect.source.SourceRecord,byte[]> valueSerializer, Function<org.apache.kafka.connect.source.SourceRecord,byte[]> keySerializer, Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord> recordFlattening, com.fasterxml.jackson.databind.ObjectMapper mapper, CdcSupplierProperties cdcStreamingEngineProperties)
void	setBeanClassLoader(ClassLoader classLoader)

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

CdcSupplierConfiguration

public CdcSupplierConfiguration()

Method Detail

setBeanClassLoader

public void setBeanClassLoader(ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAware

cdcSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> cdcSupplier(EmbeddedEngineExecutorService embeddedEngineExecutorService)

embeddedEngineExecutorService

@Bean
public EmbeddedEngineExecutorService embeddedEngineExecutorService(EmbeddedEngine.Builder embeddedEngineBuilder,
                                                                         Function<org.apache.kafka.connect.source.SourceRecord,byte[]> valueSerializer,
                                                                         Function<org.apache.kafka.connect.source.SourceRecord,byte[]> keySerializer,
                                                                         Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord> recordFlattening,
                                                                         com.fasterxml.jackson.databind.ObjectMapper mapper,
                                                                         CdcSupplierProperties cdcStreamingEngineProperties)