See: Description
| Interface | Description |
|---|---|
| SourceConnectorContext |
A context to allow a
SourceConnector to interact with the Kafka Connect runtime. |
| SourceTaskContext |
SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying
runtime.
|
| TransactionContext |
Provided to source tasks to allow them to define their own producer transaction boundaries when
exactly-once support is enabled.
|
| Class | Description |
|---|---|
| SourceConnector |
SourceConnectors implement the connector interface to pull data from another system and send
it to Kafka.
|
| SourceRecord |
SourceRecords are generated by
SourceTasks and passed to Kafka Connect for storage in
Kafka. |
| SourceTask |
SourceTask is a Task that pulls records from another system for storage in Kafka.
|
| Enum | Description |
|---|---|
| ConnectorTransactionBoundaries |
An enum to represent the level of support for connector-defined transaction boundaries.
|
| ExactlyOnceSupport |
An enum to represent the level of support for exactly-once semantics from a source connector.
|
| SourceTask.TransactionBoundary |
Represents the permitted values for the
SourceTask.TRANSACTION_BOUNDARY_CONFIG property. |