All Packages
Package Summary
Package
Description
Provides a Kafka client for performing administrative operations (such as creating topics and configuring brokers) on a Kafka cluster.
Provides a Kafka client for consuming records from topics and/or partitions in a Kafka cluster.
Provides a Kafka client for producing records to topics and/or partitions in a Kafka cluster.
Provides shared functionality for Kafka clients and servers.
Provides classes representing Access Control Lists for authorization of clients
Provides annotations used on Kafka APIs.
Provides common mechanisms for defining, parsing, validating, and documenting user-configurable parameters.
Provides a pluggable interface and some implementations for late-binding in configuration values.
Provides common exception classes.
Provides API for application-defined metadata attached to Kafka records.
Provides the API used by Kafka clients to emit metrics which are then exposed using the *
MetricsReporter interface.Provides methods of statistically aggregating metrics upon emission.
Provides mechanisms for enforcing resource quotas.
Provides client handles representing logical resources in a Kafka cluster.
Provides pluggable interfaces for implementing Kafka authentication mechanisms.
Provides a
LoginModule for using OAuth Bearer Token authentication with Kafka clusters.This package is deprecated.
Provides implementation to use plaintext credentials authentication for securing Kafka clusters.
Provides adaptor to use the Salted Challenge Response Authentication Mechanism for securing Kafka clusters.
Provides mechanism for delegating authorization to a distinct Principal for securing Kafka clusters.
Provides interface and some implementations of serialization/deserialization routines for various objects.
Provides common interfaces used to describe pluggable components.
Provides interfaces for Connector and Task implementations.
Provides pluggable interfaces for policies controlling how users can configure connectors.
Provides classes for representing data and schemas handled by Connect.
Provides common exception classes for Connect, used by the framework and plugins to communicate failures.
Provides an API for application-defined metadata attached to Connect records.
Provides an API for describing the state of a running Connect cluster to
ConnectRestExtension instances.Provides APIs for the MirrorMaker connectors and utilities to manage MirrorMaker resources.
Provides a pluggable interface for altering the behavior of the Connect REST API.
Provides an API for implementing sink connectors which write Kafka records to external applications.
Provides an API for implementing source connectors which read data from external applications into Kafka.
Provides pluggable interfaces and some implementations for (de)serializing data to and from Kafka
Provides source and sink connector implementations used for testing
Provides a pluggable interface for altering data which is being moved by Connect.
Provides a pluggable interface for describing when a
Transformation should be applied to a record.Provides common utilities that can be used in component implementations.
Provides pluggable interface for performing authorization on a Kafka server.
Provides a pluggable API for defining remote storage and retrieval of Kafka log segments.
Provides pluggable interfaces for expressing policies on topics and configs.
Provides pluggable interface for enforcing client quotas from a Kafka server.
Provides pluggable interface for capturing client telemetry metrics.
Provides the Kafka Streams library for building streaming data applications.
Provides common exception classes for Streams applications.
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
Provides interfaces for managing the intermediate state of a stateful streams application.
Provides classes for testing Kafka Streams applications with mocked inputs.
Provides interfaces for writing plugins of kafka tools