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
|
Metric |
A numerical metric tracked for monitoring purposes
|
Class | Description |
---|---|
Cluster |
A representation of a subset of the nodes, topics, and partitions in the Kafka cluster.
|
ClusterResource |
The
ClusterResource class encapsulates metadata for a Kafka cluster. |
KafkaFuture<T> |
A flexible future which supports call chaining and other asynchronous programming patterns.
|
KafkaFuture.BiConsumer<A,B> |
A consumer of two different types of object.
|
KafkaFuture.Function<A,B> |
A function which takes objects of type A and returns objects of type B.
|
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 |
Information about a topic-partition.
|
TopicPartition |
A topic name and partition number
|
TopicPartitionInfo |
A class containing leadership, replicas and ISR information for a topic partition.
|
Exception | Description |
---|---|
KafkaException |
The base class of all other Kafka exceptions
|