org.springframework.cloud.fn.common.cdc

Interface EmbeddedEngine.Builder

All Superinterfaces:

io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

All Known Implementing Classes:

EmbeddedEngine.BuilderImpl

Enclosing class:

EmbeddedEngine

Deprecated.

@Deprecated
public static interface EmbeddedEngine.Builder
extends io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

A builder to set up and create EmbeddedEngine instances.

Method Summary

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

Methods inherited from interface io.debezium.engine.DebeziumEngine.Builder

using, using, using, using

Method Detail

using

EmbeddedEngine.Builder using(io.debezium.config.Configuration config)

Deprecated.

Use the specified configuration for the connector. The configuration is assumed to already be valid.

Parameters:

config - the configuration

Returns:

this builder object so methods can be chained together; never null

using

EmbeddedEngine.Builder using(io.debezium.util.Clock clock)

Deprecated.

Use the specified clock when needing to determine the current time. Passing null or not calling this method results in the connector using the system clock.

Parameters:

clock - the clock

Returns:

this builder object so methods can be chained together; never null

notifying

EmbeddedEngine.Builder notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer)

Deprecated.

Specified by:

notifying in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

notifying

EmbeddedEngine.Builder notifying(io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord> handler)

Deprecated.

Specified by:

notifying in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

using

EmbeddedEngine.Builder using(ClassLoader classLoader)

Deprecated.

Specified by:

using in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

using

EmbeddedEngine.Builder using(EmbeddedEngine.CompletionCallback completionCallback)

Deprecated.

using

EmbeddedEngine.Builder using(EmbeddedEngine.ConnectorCallback connectorCallback)

Deprecated.

using

EmbeddedEngine.Builder using(io.debezium.engine.spi.OffsetCommitPolicy policy)

Deprecated.

Specified by:

using in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>

offsetBackingStore

EmbeddedEngine.Builder offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)

Deprecated.

build

EmbeddedEngine build()

Deprecated.

Specified by:

build in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>