public interface SourceTaskContext
OffsetStorageReader
offsetStorageReader()
OffsetStorageReader offsetStorageReader()