| 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. |