Package org.apache.kafka.common
package org.apache.kafka.common
Provides shared functionality for Kafka clients and servers.
-
ClassDescriptionAn immutable representation of a subset of the nodes, topics, and partitions in the Kafka cluster.The
ClusterResourceclass encapsulates metadata for a Kafka cluster.A callback interface that users can implement when they wish to get notified about changes in the Cluster metadata.A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parametersThe consumer group state.Represents a broker endpoint.The base class of all other Kafka exceptionsKafkaFuture<T>A flexible future which supports call chaining and other asynchronous programming patterns.A function which takes objects of type A and returns objects of type B.A consumer of two different types of object.KafkaFuture.Function<A,B> Deprecated.Since Kafka 3.0.This interface allows to define Formatters that can be used to parse and format records read by a Consumer instance for display.A metric tracked for monitoring purposes.TheMetricNameclass encapsulates a metric's name, logical group and its related attributes.A template for a MetricName.Information about a Kafka nodeThis is used to describe per-partition state in the MetadataResponse.Interface for reconfigurable classes that support dynamic configuration.A class used to represent a collection of topics.A class used to represent a collection of topics defined by their topic ID.A class used to represent a collection of topics defined by their topic name.This represents universally unique identifier with topic id for a topic partition.A topic name and partition numberA class containing leadership, replicas and ISR information for a topic partition.The topic name, partition number and the brokerId of the replicaThis class defines an immutable universally unique identifier (UUID).