@Deprecated public static interface EmbeddedEngine.Builder extends io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
EmbeddedEngine
instances.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.
|
EmbeddedEngine.Builder using(io.debezium.config.Configuration config)
config
- the configurationEmbeddedEngine.Builder using(io.debezium.util.Clock clock)
null
or not calling this
method results in the connector using the system clock
.clock
- the clockEmbeddedEngine.Builder notifying(Consumer<org.apache.kafka.connect.source.SourceRecord> consumer)
notifying
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
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>
EmbeddedEngine.Builder using(ClassLoader classLoader)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
EmbeddedEngine.Builder using(EmbeddedEngine.CompletionCallback completionCallback)
EmbeddedEngine.Builder using(EmbeddedEngine.ConnectorCallback connectorCallback)
EmbeddedEngine.Builder using(io.debezium.engine.spi.OffsetCommitPolicy policy)
using
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
EmbeddedEngine.Builder offsetBackingStore(org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore)
EmbeddedEngine build()
build
in interface io.debezium.engine.DebeziumEngine.Builder<org.apache.kafka.connect.source.SourceRecord>
Copyright © 2022. All rights reserved.