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
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 semantics from a source connector.
Represents the permitted values for the