Package io.debezium.embedded

Class TestingEmbeddedEngine

java.lang.Object

io.debezium.embedded.TestingEmbeddedEngine

All Implemented Interfaces:

TestingDebeziumEngine<org.apache.kafka.connect.source.SourceRecord>, io.debezium.engine.DebeziumEngine<org.apache.kafka.connect.source.SourceRecord>, Closeable, AutoCloseable, Runnable

public class TestingEmbeddedEngine
extends Object
implements TestingDebeziumEngine<org.apache.kafka.connect.source.SourceRecord>

Implementation of TestingDebeziumEngine for EmbeddedEngine.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.engine.DebeziumEngine

io.debezium.engine.DebeziumEngine.Builder<R>, io.debezium.engine.DebeziumEngine.BuilderFactory, io.debezium.engine.DebeziumEngine.ChangeConsumer<R>, io.debezium.engine.DebeziumEngine.CompletionCallback, io.debezium.engine.DebeziumEngine.ConnectorCallback, io.debezium.engine.DebeziumEngine.Offsets, io.debezium.engine.DebeziumEngine.RecordCommitter<R>, io.debezium.engine.DebeziumEngine.Signal, io.debezium.engine.DebeziumEngine.Signaler

Field Summary

Fields

Modifier and Type	Field	Description
private final io.debezium.embedded.EmbeddedEngine	engine

Fields inherited from interface io.debezium.engine.DebeziumEngine

OFFSET_FLUSH_INTERVAL_MS_PROP

Constructor Summary

Constructors

Constructor	Description
TestingEmbeddedEngine(io.debezium.embedded.EmbeddedEngine engine)

Method Summary

Modifier and Type	Method	Description
void	close()
void	run()
void	runWithTask(Consumer<org.apache.kafka.connect.source.SourceTask> consumer)	Run consumer function with engine task, e.g.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.engine.DebeziumEngine

getSignaler

Field Details

engine

private final io.debezium.embedded.EmbeddedEngine engine

Constructor Details

TestingEmbeddedEngine

public TestingEmbeddedEngine(io.debezium.embedded.EmbeddedEngine engine)

Method Details

run

public void run()

Specified by:

run in interface Runnable

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

runWithTask

public void runWithTask(Consumer<org.apache.kafka.connect.source.SourceTask> consumer)

Description copied from interface: TestingDebeziumEngine

Run consumer function with engine task, e.g. in case of Kafka with SourceTask. Effectively expose engine internal task for testing.

Specified by:

runWithTask in interface TestingDebeziumEngine<org.apache.kafka.connect.source.SourceRecord>