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.

Class	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.
SourceConnector	SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.
SourceConnectorContext	A context to allow a SourceConnector to interact with the Kafka Connect runtime.
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.
SourceTask.TransactionBoundary	Represents the permitted values for the SourceTask.TRANSACTION_BOUNDARY_CONFIG property.
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.