Package org.apache.kafka.common

Provides shared functionality for Kafka clients and servers.

Interface Summary

Interface	Description
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
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.
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.
Reconfigurable	Interface for reconfigurable classes that support dynamic configuration.

Class Summary

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.
Endpoint	Represents a broker endpoint.
KafkaFuture<T>	A flexible future which supports call chaining and other asynchronous programming patterns.
KafkaFuture.Function<A,B>	Deprecated. Since Kafka 3.0.
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.
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).

Enum Summary

Enum	Description
ConsumerGroupState	The consumer group state.
ElectionType	Options for Admin.electLeaders(ElectionType, Set, org.apache.kafka.clients.admin.ElectLeadersOptions).
IsolationLevel

Exception Summary

Exception	Description
InvalidRecordException
KafkaException	The base class of all other Kafka exceptions