org.apache.kafka.connect.source

Interface SourceTaskContext

@InterfaceStability.Unstable
public interface SourceTaskContext

SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying runtime.

Method Summary

Methods

Modifier and Type	Method and Description
OffsetStorageReader	offsetStorageReader() Get the OffsetStorageReader for this SourceTask.

Method Detail

offsetStorageReader

OffsetStorageReader offsetStorageReader()

Get the OffsetStorageReader for this SourceTask.