| 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.server.authorizer | Provides pluggable interface for performing authorization on a Kafka server. |
| 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. |