org.springframework.cloud.fn.common.cdc

Class CdcCommonConfiguration

java.lang.Object

org.springframework.cloud.fn.common.cdc.CdcCommonConfiguration

@Configuration
 @EnableConfigurationProperties(value=CdcCommonProperties.class)
 @Import(value=CdcOffsetBackingStoreConfiguration.class)
public class CdcCommonConfiguration
extends Object

Author:

Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
CdcCommonConfiguration()

Method Summary

Modifier and Type	Method and Description
io.debezium.config.Configuration	configuration(CdcCommonProperties properties)
EmbeddedEngine.Builder	embeddedEngineBuilder(CdcCommonProperties properties, org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)
io.debezium.transforms.ExtractNewRecordState	extractNewRecordState(CdcCommonProperties properties)
org.apache.kafka.connect.json.JsonConverter	jsonConverter(CdcCommonProperties properties)
Function<org.apache.kafka.connect.source.SourceRecord,byte[]>	keySerializer(org.apache.kafka.connect.storage.Converter valueConverter)
Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord>	recordFlattening(CdcCommonProperties properties, io.debezium.transforms.ExtractNewRecordState extractNewRecordState)
Function<org.apache.kafka.connect.source.SourceRecord,byte[]>	valueSerializer(org.apache.kafka.connect.storage.Converter valueConverter)

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcCommonConfiguration

public CdcCommonConfiguration()

Method Detail

configuration

@Bean
public io.debezium.config.Configuration configuration(CdcCommonProperties properties)

recordFlattening

@Bean
public Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord> recordFlattening(CdcCommonProperties properties,
                                                                                                                                  io.debezium.transforms.ExtractNewRecordState extractNewRecordState)

extractNewRecordState

@Bean
public io.debezium.transforms.ExtractNewRecordState extractNewRecordState(CdcCommonProperties properties)

jsonConverter

@Bean
 @ConditionalOnMissingBean
public org.apache.kafka.connect.json.JsonConverter jsonConverter(CdcCommonProperties properties)

valueSerializer

@Bean
public Function<org.apache.kafka.connect.source.SourceRecord,byte[]> valueSerializer(org.apache.kafka.connect.storage.Converter valueConverter)

keySerializer

@Bean
public Function<org.apache.kafka.connect.source.SourceRecord,byte[]> keySerializer(org.apache.kafka.connect.storage.Converter valueConverter)

embeddedEngineBuilder

@Bean
public EmbeddedEngine.Builder embeddedEngineBuilder(CdcCommonProperties properties,
                                                          org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)