Interface SourceConnectorContext

All Superinterfaces:

ConnectorContext

@Public
public interface SourceConnectorContext
extends ConnectorContext

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

Method Summary

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

Methods inherited from interface ConnectorContext

pluginMetrics, raiseError, requestTaskReconfiguration

Method Details

offsetStorageReader

OffsetStorageReader offsetStorageReader()

Returns the OffsetStorageReader for this SourceConnectorContext.

Returns:

the OffsetStorageReader for this connector.