public static final class EmbeddedEngine.BuilderImpl extends Object implements EmbeddedEngine.Builder
Constructor and Description |
---|
BuilderImpl() |
Modifier and Type | Method and Description |
---|---|
EmbeddedEngine |
build() |
EmbeddedEngine.Builder |
notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer) |
EmbeddedEngine.Builder |
notifying(io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord> handler) |
EmbeddedEngine.Builder |
offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore) |
EmbeddedEngine.Builder |
sourceConnector(org.apache.kafka.connect.source.SourceConnector sourceConnector) |
EmbeddedEngine.Builder |
using(ClassLoader classLoader) |
EmbeddedEngine.Builder |
using(io.debezium.util.Clock clock)
Use the specified clock when needing to determine the current time.
|
EmbeddedEngine.Builder |
using(Clock clock) |
EmbeddedEngine.Builder |
using(io.debezium.config.Configuration config)
Use the specified configuration for the connector.
|
EmbeddedEngine.Builder |
using(io.debezium.engine.DebeziumEngine.CompletionCallback completionCallback) |
EmbeddedEngine.Builder |
using(io.debezium.engine.DebeziumEngine.ConnectorCallback connectorCallback) |
EmbeddedEngine.Builder |
using(EmbeddedEngine.CompletionCallback completionCallback) |
EmbeddedEngine.Builder |
using(EmbeddedEngine.ConnectorCallback connectorCallback) |
EmbeddedEngine.Builder |
using(io.debezium.engine.spi.OffsetCommitPolicy offsetCommitPolicy) |
EmbeddedEngine.Builder |
using(Properties config) |
public EmbeddedEngine.Builder sourceConnector(org.apache.kafka.connect.source.SourceConnector sourceConnector)
sourceConnector
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)
offsetBackingStore
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder using(io.debezium.config.Configuration config)
EmbeddedEngine.Builder
using
in interface EmbeddedEngine.Builder
config
- the configurationpublic EmbeddedEngine.Builder using(Properties config)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
public EmbeddedEngine.Builder using(ClassLoader classLoader)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
using
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder using(io.debezium.util.Clock clock)
EmbeddedEngine.Builder
null
or not calling this
method results in the connector using the system clock
.using
in interface EmbeddedEngine.Builder
clock
- the clockpublic EmbeddedEngine.Builder using(io.debezium.engine.DebeziumEngine.CompletionCallback completionCallback)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
public EmbeddedEngine.Builder using(io.debezium.engine.DebeziumEngine.ConnectorCallback connectorCallback)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
public EmbeddedEngine.Builder using(io.debezium.engine.spi.OffsetCommitPolicy offsetCommitPolicy)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
using
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer)
notifying
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
notifying
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder notifying(io.debezium.engine.DebeziumEngine.ChangeConsumer<org.apache.kafka.connect.source.SourceRecord> handler)
notifying
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
notifying
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder using(Clock clock)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
public EmbeddedEngine build()
build
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
build
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder using(EmbeddedEngine.CompletionCallback completionCallback)
using
in interface EmbeddedEngine.Builder
public EmbeddedEngine.Builder using(EmbeddedEngine.ConnectorCallback connectorCallback)
using
in interface EmbeddedEngine.Builder
Copyright © 2020. All rights reserved.