Package io.debezium.pipeline.spi

Interface OffsetContext.Loader<O extends OffsetContext>

Enclosing interface:

OffsetContext

public static interface OffsetContext.Loader<O extends OffsetContext>

Implementations load a connector-specific offset context based on the offset values stored in Kafka.

Method Summary

Modifier and Type	Method	Description
O	load(Map<String,?> offset)
default Optional<SnapshotType>	loadSnapshot(Map<String,?> offset)
default boolean	loadSnapshotCompleted(Map<String,?> offset)

Method Details

loadSnapshot

default Optional<SnapshotType> loadSnapshot(Map<String,?> offset)

loadSnapshotCompleted

default boolean loadSnapshotCompleted(Map<String,?> offset)

load

O load(Map<String,?> offset)