Package io.debezium.pipeline.notification.channels

Class SinkNotificationChannel.EmptyOffsetContext

java.lang.Object
io.debezium.pipeline.notification.channels.SinkNotificationChannel.EmptyOffsetContext
All Implemented Interfaces:
OffsetContext
Enclosing class:
SinkNotificationChannel
private static class SinkNotificationChannel.EmptyOffsetContext extends Object implements OffsetContext

  • Constructor Details

    • EmptyOffsetContext

      private EmptyOffsetContext()

  • Method Details

    • getOffset

      public Map<String,?> getOffset()
      Specified by:
      getOffset in interface OffsetContext

    • getSourceInfoSchema

      public org.apache.kafka.connect.data.Schema getSourceInfoSchema()
      Specified by:
      getSourceInfoSchema in interface OffsetContext

    • getSourceInfo

      public org.apache.kafka.connect.data.Struct getSourceInfo()
      Specified by:
      getSourceInfo in interface OffsetContext

    • isInitialSnapshotRunning

      public boolean isInitialSnapshotRunning()
      Description copied from interface: OffsetContext
      Whether this offset indicates that an (uncompleted) snapshot is currently running or not.
      Specified by:
      isInitialSnapshotRunning in interface OffsetContext
      Returns:

    • markSnapshotRecord

      public void markSnapshotRecord(SnapshotRecord record)
      Description copied from interface: OffsetContext
      Mark the position of the record in the snapshot.
      Specified by:
      markSnapshotRecord in interface OffsetContext

    • preSnapshotStart

      public void preSnapshotStart(boolean onDemand)
      Description copied from interface: OffsetContext
      Signals that a snapshot will begin, which should reflect in an updated offset state.
      Specified by:
      preSnapshotStart in interface OffsetContext
      Parameters:
      onDemand - indicates whether the snapshot is initial or blocking

    • preSnapshotCompletion

      public void preSnapshotCompletion()
      Description copied from interface: OffsetContext
      Signals that a snapshot will complete, which should reflect in an updated offset state.
      Specified by:
      preSnapshotCompletion in interface OffsetContext

    • postSnapshotCompletion

      public void postSnapshotCompletion()
      Description copied from interface: OffsetContext
      Signals that a snapshot has been completed, which should reflect in an updated offset state.
      Specified by:
      postSnapshotCompletion in interface OffsetContext

    • event

      public void event(io.debezium.spi.schema.DataCollectionId collectionId, Instant timestamp)
      Description copied from interface: OffsetContext
      Records the name of the collection and the timestamp of the last event
      Specified by:
      event in interface OffsetContext

    • getTransactionContext

      public TransactionContext getTransactionContext()
      Description copied from interface: OffsetContext
      Provide a context used by TransactionMonitor so persist its internal state into offsets to survive between restarts.
      Specified by:
      getTransactionContext in interface OffsetContext
      Returns:
      transaction context