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 |
---|---|
CellMigrationState |
Represents the state of cell migration
|
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 | |
GroupType | |
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 |