Package org.apache.kafka.common

package org.apache.kafka.common

Provides shared functionality for Kafka clients and servers.

Related Packages

Package	Description
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.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.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.serialization	Provides interface and some implementations of serialization/deserialization routines for various objects.

Class	Description
Cluster	An immutable representation of a subset of the nodes, topics, and partitions in the Kafka cluster.
ClusterResource	The ClusterResource class encapsulates metadata for a Kafka cluster.
ClusterResourceListener	A callback interface that users can implement when they wish to get notified about changes in the Cluster metadata.
Configurable	A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters
ConsumerGroupState	The consumer group state.
ElectionType	Options for Admin.electLeaders(ElectionType, Set, org.apache.kafka.clients.admin.ElectLeadersOptions).
Endpoint	Represents a broker endpoint.
GroupType
InvalidRecordException
IsolationLevel
KafkaException	The base class of all other Kafka exceptions
KafkaFuture<T>	A flexible future which supports call chaining and other asynchronous programming patterns.
KafkaFuture.BaseFunction<A,B>	A function which takes objects of type A and returns objects of type B.
KafkaFuture.BiConsumer<A,B>	A consumer of two different types of object.
KafkaFuture.Function<A,B>	Deprecated. Since Kafka 3.0.
MessageFormatter	This interface allows to define Formatters that can be used to parse and format records read by a Consumer instance for display.
Metric	A metric tracked for monitoring purposes.
MetricName	The MetricName class encapsulates a metric's name, logical group and its related attributes.
MetricNameTemplate	A template for a MetricName.
Node	Information about a Kafka node
PartitionInfo	This is used to describe per-partition state in the MetadataResponse.
Reconfigurable	Interface for reconfigurable classes that support dynamic configuration.
ShareGroupState	The share group state.
TopicCollection	A class used to represent a collection of topics.
TopicCollection.TopicIdCollection	A class used to represent a collection of topics defined by their topic ID.
TopicCollection.TopicNameCollection	A class used to represent a collection of topics defined by their topic name.
TopicIdPartition	This represents universally unique identifier with topic id for a topic partition.
TopicPartition	A topic name and partition number
TopicPartitionInfo	A class containing leadership, replicas and ISR information for a topic partition.
TopicPartitionReplica	The topic name, partition number and the brokerId of the replica
Uuid	This class defines an immutable universally unique identifier (UUID).