Package org.apache.kafka.connect.source
package org.apache.kafka.connect.source
Provides an API for implementing source connectors which read data from external applications into Kafka.
-
ClassDescriptionAn 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.SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.A context to allow a
SourceConnector
to interact with the Kafka Connect runtime.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.Represents the permitted values for theSourceTask.TRANSACTION_BOUNDARY_CONFIG
property.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.