Package io.debezium.embedded.async

Class TestingAsyncEmbeddedEngine<T>

java.lang.Object
io.debezium.embedded.async.TestingAsyncEmbeddedEngine<T>
All Implemented Interfaces:
TestingDebeziumEngine<T>, io.debezium.engine.DebeziumEngine<T>, Closeable, AutoCloseable, Runnable
public class TestingAsyncEmbeddedEngine<T> extends Object implements TestingDebeziumEngine<T>
Implementation of TestingDebeziumEngine for AsyncEngineConfig.
Author:
vjuranek

  • 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.async.AsyncEmbeddedEngine<T>
    engine
     

    Fields inherited from interface io.debezium.engine.DebeziumEngine

    OFFSET_FLUSH_INTERVAL_MS_PROP

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestingAsyncEmbeddedEngine(io.debezium.embedded.async.AsyncEmbeddedEngine<T> engine)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    io.debezium.engine.DebeziumEngine.Signaler
    getSignaler()
     
    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

  • Field Details

    • engine

      private final io.debezium.embedded.async.AsyncEmbeddedEngine<T> engine

  • Constructor Details

    • TestingAsyncEmbeddedEngine

      public TestingAsyncEmbeddedEngine(io.debezium.embedded.async.AsyncEmbeddedEngine<T> 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<T>

    • getSignaler

      public io.debezium.engine.DebeziumEngine.Signaler getSignaler()
      Specified by:
      getSignaler in interface io.debezium.engine.DebeziumEngine<T>