Class RecoverySnapshotter

All Implemented Interfaces:
BeanRegistryAware, io.debezium.spi.common.Configurable, io.debezium.spi.snapshot.Snapshotter

public class RecoverySnapshotter extends NoDataSnapshotter
  • Constructor Details

    • RecoverySnapshotter

      public RecoverySnapshotter()
  • Method Details

    • name

      public String name()
      Specified by:
      name in interface io.debezium.spi.snapshot.Snapshotter
      Overrides:
      name in class NoDataSnapshotter
    • shouldSnapshotSchema

      public boolean shouldSnapshotSchema(boolean offsetExists, boolean snapshotInProgress)
      Specified by:
      shouldSnapshotSchema in interface io.debezium.spi.snapshot.Snapshotter
      Overrides:
      shouldSnapshotSchema in class NoDataSnapshotter
    • shouldSnapshotOnSchemaError

      public boolean shouldSnapshotOnSchemaError()
      Specified by:
      shouldSnapshotOnSchemaError in interface io.debezium.spi.snapshot.Snapshotter
      Overrides:
      shouldSnapshotOnSchemaError in class NoDataSnapshotter
    • shouldStreamEventsStartingFromSnapshot

      public boolean shouldStreamEventsStartingFromSnapshot()