A context to allow a
SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying runtime.
Provided to source tasks to allow them to define their own producer transaction boundaries when exactly-once support is enabled.
SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.
SourceRecords are generated by SourceTasks and passed to Kafka Connect for storage in Kafka.
SourceTask is a Task that pulls records from another system for storage in Kafka.
An enum to represent the level of support for connector-defined transaction boundaries.
An enum to represent the level of support for exactly-once delivery from a source connector.
Represents the permitted values for the