org.springframework.cloud.fn.common.cdc

Class CdcOffsetBackingStoreConfiguration

java.lang.Object

org.springframework.cloud.fn.common.cdc.CdcOffsetBackingStoreConfiguration

@Configuration
public class CdcOffsetBackingStoreConfiguration
extends Object

Author:

Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
CdcOffsetBackingStoreConfiguration()

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.connect.storage.OffsetBackingStore	fileOffsetBackingStore()
org.apache.kafka.connect.storage.OffsetBackingStore	kafkaOffsetBackingStore()
org.apache.kafka.connect.storage.OffsetBackingStore	memoryOffsetBackingStore()
org.apache.kafka.connect.storage.OffsetBackingStore	metadataStoreOffsetBackingStore(org.springframework.integration.metadata.MetadataStore metadataStore)

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcOffsetBackingStoreConfiguration

public CdcOffsetBackingStoreConfiguration()

Method Detail

metadataStoreOffsetBackingStore

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnExpression(value="\'${cdc.config.offset.storage}\'.equalsIgnoreCase(\'org.springframework.cloud.stream.app.cdc.common.core.store.MetadataStoreOffsetBackingStore\') or \'${cdc.offset.storage:metadata}\'.equals(\'metadata\')")
public org.apache.kafka.connect.storage.OffsetBackingStore metadataStoreOffsetBackingStore(org.springframework.integration.metadata.MetadataStore metadataStore)

fileOffsetBackingStore

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnExpression(value="\'${cdc.config.offset.storage}\'.equalsIgnoreCase(\'org.apache.kafka.connect.storage.FileOffsetBackingStore\') or \'${cdc.offset.storage:metadata}\'.equalsIgnoreCase(\'file\')")
public org.apache.kafka.connect.storage.OffsetBackingStore fileOffsetBackingStore()

kafkaOffsetBackingStore

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnExpression(value="\'${cdc.config.offset.storage}\'.equalsIgnoreCase(\'org.apache.kafka.connect.storage.KafkaOffsetBackingStore\') or \'${cdc.offset.storage:metadata}\'.equalsIgnoreCase(\'kafka\')")
public org.apache.kafka.connect.storage.OffsetBackingStore kafkaOffsetBackingStore()

memoryOffsetBackingStore

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnExpression(value="\'${cdc.config.offset.storage}\'.equalsIgnoreCase(\'org.apache.kafka.connect.storage.MemoryOffsetBackingStore\') or \'${cdc.offset.storage:metadata}\'.equalsIgnoreCase(\'memory\')")
public org.apache.kafka.connect.storage.OffsetBackingStore memoryOffsetBackingStore()