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. |