See: Description
| 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 | Description |
|---|---|
| Cell | Represents the contents of a cell, a collection of brokers. |
| CellLoad | Represents load information about a cell. |
| 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. |
| ConfluentNode | Information about a Confluent Server node. |
| DelegatingReconfigurable | |
| 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. |
| Tenant | Represents the contents of a tenant. |
| 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 | Description |
|---|---|
| CellState | Represents the state of a cell, mostly indicating whether tenants can be moved in or out of a cell. |
| ClusterLinkError | Encodes a reason for why a link is in some sort of error state. |
| ConsumerGroupState | The consumer group state. |
| ElectionType | |
| IsolationLevel | |
| MirrorTopicError | Reason for persistent failure of a mirror topic. |
| PartitionPlacementStrategy | Represents different ways partitions and its replicas can be placed across the cluster. |
| Exception | Description |
|---|---|
| InvalidRecordException | |
| KafkaException | The base class of all other Kafka exceptions |
| Annotation Type | Description |
|---|---|
| Confluent |