Package org.apache.kafka.common

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>	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	This is used to describe per-partition state in the MetadataResponse.
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

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