public interface SourceConnectorContext extends ConnectorContext
SourceConnector to interact with the Kafka Connect runtime.| Modifier and Type | Method and Description |
|---|---|
OffsetStorageReader | offsetStorageReader()Returns the OffsetStorageReader for this SourceConnectorContext. |
raiseError, requestTaskReconfigurationOffsetStorageReader offsetStorageReader()
OffsetStorageReader for this SourceConnectorContext.