clients 3.6.1.0-eep-930 API

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