| Package | Description |
|---|---|
| org.apache.kafka.clients.admin |
Provides a Kafka client for performing administrative operations (such as creating topics and configuring brokers) on a Kafka cluster.
|
| org.apache.kafka.clients.consumer |
Provides a Kafka client for consuming records from topics and/or partitions in a Kafka cluster.
|
| org.apache.kafka.clients.producer |
Provides a Kafka client for producing records to topics and/or partitions in a Kafka cluster.
|
| org.apache.kafka.common |
Provides shared functionality for Kafka clients and servers.
|
| org.apache.kafka.common.acl |
Provides classes representing Access Control Lists for authorization of clients
|
| org.apache.kafka.common.annotation |
Provides annotations used on Kafka APIs.
|
| org.apache.kafka.common.config |
Provides common mechanisms for defining, parsing, validating, and documenting user-configurable parameters.
|
| org.apache.kafka.common.config.provider |
Provides a pluggable interface and some implementations for late-binding in configuration values.
|
| org.apache.kafka.common.errors |
Provides common exception classes.
|
| org.apache.kafka.common.header |
Provides API for application-defined metadata attached to Kafka records.
|
| org.apache.kafka.common.metrics |
Provides the API used by Kafka clients to emit metrics which are then exposed using the *
MetricsReporter interface. |
| org.apache.kafka.common.metrics.stats |
Provides methods of statistically aggregating metrics upon emission.
|
| org.apache.kafka.common.quota |
Provides mechanisms for enforcing resource quotas.
|
| org.apache.kafka.common.resource |
Provides client handles representing logical resources in a Kafka cluster.
|
| org.apache.kafka.common.security.auth |
Provides pluggable interfaces for implementing Kafka authentication mechanisms.
|
| org.apache.kafka.common.security.oauthbearer |
Provides a
LoginModule for using OAuth Bearer Token authentication with Kafka clusters. |
| org.apache.kafka.common.security.oauthbearer.secured |
This package is deprecated.
|
| org.apache.kafka.common.security.plain |
Provides implementation to use plaintext credentials authentication for securing Kafka clusters.
|
| org.apache.kafka.common.security.scram |
Provides adaptor to use the Salted Challenge Response Authentication Mechanism for securing Kafka clusters.
|
| org.apache.kafka.common.security.token.delegation |
Provides mechanism for delegating authorization to a distinct Principal for securing Kafka clusters.
|
| org.apache.kafka.common.serialization |
Provides interface and some implementations of serialization/deserialization routines for various objects.
|
| 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.mirror | |
| 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.tools | |
| 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.
|
| org.apache.kafka.server.authorizer |
Provides pluggable interface for performing authorization on a Kafka server.
|
| org.apache.kafka.server.log.remote.storage |
Provides a pluggable API for defining remote storage and retrieval of Kafka log segments.
|
| org.apache.kafka.server.policy |
Provides pluggable interfaces for expressing policies on topics and configs.
|
| org.apache.kafka.server.quota |
Provides pluggable interface for enforcing client quotas from a Kafka server.
|
| org.apache.kafka.server.telemetry |
Provides pluggable interface for capturing client telemetry metrics.
|
| org.apache.kafka.streams |
Provides the Kafka Streams library for building streaming data applications.
|
| org.apache.kafka.streams.errors |
Provides common exception classes for Streams applications.
|
| org.apache.kafka.streams.kstream | |
| org.apache.kafka.streams.processor |
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
|
| org.apache.kafka.streams.processor.api |
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
|
| org.apache.kafka.streams.query |
Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
|
| org.apache.kafka.streams.state |
Provides interfaces for managing the intermediate state of a stateful streams application.
|
| org.apache.kafka.streams.test |
Provides classes for testing Kafka Streams applications with mocked inputs.
|
| org.apache.kafka.tools.api |
Provides interfaces for writing plugins of kafka tools
|