Uses of Interface
org.springframework.cloud.fn.common.cdc.EmbeddedEngine.Builder

Packages that use EmbeddedEngine.Builder

Package	Description
org.springframework.cloud.fn.common.cdc
org.springframework.cloud.fn.supplier.cdc

Uses of EmbeddedEngine.Builder in org.springframework.cloud.fn.common.cdc

Classes in org.springframework.cloud.fn.common.cdc that implement EmbeddedEngine.Builder

Modifier and Type	Class and Description
static class	EmbeddedEngine.BuilderImpl

Methods in org.springframework.cloud.fn.common.cdc that return EmbeddedEngine.Builder

Modifier and Type	Method and Description
static EmbeddedEngine.Builder	EmbeddedEngine.create() Deprecated.
EmbeddedEngine.Builder	CdcCommonConfiguration.embeddedEngineBuilder(CdcCommonProperties properties, org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.notifying(io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord> handler)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.notifying(io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord> handler) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(ClassLoader classLoader)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(ClassLoader classLoader) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(io.debezium.util.Clock clock)
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(Clock clock)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(io.debezium.util.Clock clock) Deprecated. Use the specified clock when needing to determine the current time.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(io.debezium.config.Configuration config)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(io.debezium.config.Configuration config) Deprecated. Use the specified configuration for the connector.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(io.debezium.engine.DebeziumEngine.CompletionCallback completionCallback)
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(io.debezium.engine.DebeziumEngine.ConnectorCallback connectorCallback)
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(EmbeddedEngine.CompletionCallback completionCallback)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(EmbeddedEngine.CompletionCallback completionCallback) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(EmbeddedEngine.ConnectorCallback connectorCallback)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(EmbeddedEngine.ConnectorCallback connectorCallback) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(io.debezium.engine.spi.OffsetCommitPolicy offsetCommitPolicy)
EmbeddedEngine.Builder	EmbeddedEngine.Builder.using(io.debezium.engine.spi.OffsetCommitPolicy policy) Deprecated.
EmbeddedEngine.Builder	EmbeddedEngine.BuilderImpl.using(Properties config)

Uses of EmbeddedEngine.Builder in org.springframework.cloud.fn.supplier.cdc

Methods in org.springframework.cloud.fn.supplier.cdc with parameters of type EmbeddedEngine.Builder

Modifier and Type

Method and Description

EmbeddedEngineExecutorService

CdcSupplierConfiguration.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)