org.apache.kafka.connect.source

Interface SourceTaskContext

public interface SourceTaskContext

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

Method Summary

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.