All Classes and Interfaces
Class
Description
Provides the current status for a connector or a task, along with an identifier for its Connect worker
Indicates the operation tried to create an entity that already exists.
Provides immutable Connect cluster information, such as the ID of the backing Kafka cluster.
Provides the ability to lookup connector metadata, including status and configurations, as well
as immutable cluster information such as Kafka cluster ID.
ConnectException is the top-level exception type generated by Kafka Connect and connector implementations.
A basic
Headers implementation.
Connectors manage integration of Kafka Connect with another system, either as an input that ingests
data into Kafka or an output that passes data to an external system.
An interface for enforcing a policy on overriding of Kafka client configs via the connector configs.
ConnectorContext allows
Connectors to proactively interact with the Kafka Connect runtime.Provides basic health information about the connector and its tasks.
Describes the status, worker ID, and any errors associated with a connector.
An enum to represent the level of support for connector-defined transaction boundaries.
Enum definition that identifies the type of the connector.
Utilities that connector implementations might find useful.
Base class for records containing data to be copied to/from Kafka.
A plugin interface to allow registration of new JAX-RS resources like Filters, REST endpoints, providers, etc.
The interface provides the ability for
ConnectRestExtension implementations to access the JAX-RS
Configurable and cluster state ConnectClusterState.The Converter interface provides support for translating between Kafka Connect's runtime data format
and byte[].
Abstract class that defines the configuration options for
Converter and HeaderConverter instances.The type of
Converter and HeaderConverter.Base class for all Kafka Connect data API exceptions.
A date representing a calendar day with no time of day or timezone.
An arbitrary-precision signed decimal number.
Component that a
SinkTask can use to report problematic records (and their corresponding problems) as it
writes them through SinkTask.put(java.util.Collection).An enum to represent the level of support for exactly-once semantics from a source connector.
A
Header is a key-value pair, and multiple headers can be included with the key, value, and timestamp in each Kafka message.The HeaderConverter interface provides support for translating between Kafka Connect's runtime data format
and byte[].
A mutable ordered collection of
Header objects.A function to transform the supplied
Header.Indicates that a method has been invoked illegally or at an invalid time by a connector or task.
Indicates that an operation attempted to modify or delete a connector or task that is not present on the worker.
OffsetStorageReader provides access to the offset storage used by sources.
A predicate on records.
An exception that indicates the operation can be reattempted.
Definition of an abstract data type.
The type of a schema.
A composite containing a
Schema and associated value
SchemaBuilder provides a fluent API for constructing
Schema objects.Indicates an error while building a schema via
SchemaBuilder
SchemaProjector is a utility to project a value between compatible schemas and throw exceptions
when non compatible schemas are provided.
Indicates an error while projecting a schema via
SchemaProjectorA
HeaderConverter that serializes header values as strings and that deserializes header values to the most appropriate
numeric, boolean, array, or map representation.SinkConnectors implement the Connector interface to send Kafka data to another system.
A context to allow a
SinkConnector to interact with the Kafka Connect runtime.SinkRecord is a
ConnectRecord that has been read from Kafka and includes the original Kafka record's
topic, partition and offset (before any transformations have been applied)
in addition to the standard fields.SinkTask is a Task that takes records loaded from Kafka and sends them to another system.
Context passed to
SinkTasks, allowing them to access utilities in the Kafka Connect runtime.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 the
SourceTask.TRANSACTION_BOUNDARY_CONFIG property.SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying
runtime.
Converter and HeaderConverter implementation that only supports serializing to strings.Configuration options for
StringConverter instances.
A structured record containing a set of named fields with values, each field using an independent
Schema.
Tasks contain the code that actually copies data to/from another system.
Describes the state, IDs, and any errors of a connector task.
A time representing a specific point in a day, not tied to any specific date.
A timestamp representing an absolute time, without timezone information.
Provided to source tasks to allow them to define their own producer transaction boundaries when
exactly-once support is enabled.
Single message transformation for Kafka Connect record types.
Utility for converting from one Connect value to a different form.
Connect requires some components implement this interface to define a version string.