org.apache.kafka.connect.source

Interface SourceConnectorContext

All Superinterfaces:

ConnectorContext

public interface SourceConnectorContext
extends ConnectorContext

A context to allow a SourceConnector to interact with the Kafka Connect runtime.

Method Summary

Modifier and Type	Method and Description
OffsetStorageReader	offsetStorageReader() Returns the OffsetStorageReader for this SourceConnectorContext.

Methods inherited from interface org.apache.kafka.connect.connector.ConnectorContext

raiseError, requestTaskReconfiguration

Method Detail

offsetStorageReader

OffsetStorageReader offsetStorageReader()

Returns the OffsetStorageReader for this SourceConnectorContext.

Returns:

the OffsetStorageReader for this connector.