| Package | Description |
|---|---|
| org.apache.kafka.connect.components |
Provides common interfaces used to describe pluggable components.
|
| org.apache.kafka.connect.connector |
Provides interfaces for Connector and Task implementations.
|
| org.apache.kafka.connect.connector.policy |
Provides pluggable interfaces for policies controlling how users can configure connectors.
|
| org.apache.kafka.connect.data |
Provides classes for representing data and schemas handled by Connect.
|
| org.apache.kafka.connect.errors |
Provides common exception classes for Connect, used by the framework and plugins to communicate failures.
|
| org.apache.kafka.connect.header |
Provides an API for application-defined metadata attached to Connect records.
|
| org.apache.kafka.connect.health |
Provides an API for describing the state of a running Connect cluster to
ConnectRestExtension instances. |
| org.apache.kafka.connect.rest |
Provides a pluggable interface for altering the behavior of the Connect REST API.
|
| org.apache.kafka.connect.sink |
Provides an API for implementing sink connectors which write Kafka records to external applications.
|
| org.apache.kafka.connect.source |
Provides an API for implementing source connectors which read data from external applications into Kafka.
|
| org.apache.kafka.connect.storage |
Provides pluggable interfaces and some implementations for (de)serializing data to and from Kafka
|
| org.apache.kafka.connect.transforms |
Provides a pluggable interface for altering data which is being moved by Connect.
|
| org.apache.kafka.connect.transforms.predicates |
Provides a pluggable interface for describing when a
Transformation should be applied to a record. |
| org.apache.kafka.connect.util |
Provides common utilities that can be used in component implementations.
|