Class Hierarchy
- java.lang.Object
- org.apache.kafka.common.Cluster
- org.apache.kafka.common.ClusterResource
- org.apache.kafka.common.Endpoint
- org.apache.kafka.common.KafkaFuture<T> (implements java.util.concurrent.Future<V>)
- org.apache.kafka.common.KafkaFuture.Function<A,B> (implements org.apache.kafka.common.KafkaFuture.BaseFunction<A,B>)
- org.apache.kafka.common.MetricName
- org.apache.kafka.common.MetricNameTemplate
- org.apache.kafka.common.Node
- org.apache.kafka.common.PartitionInfo
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- org.apache.kafka.common.KafkaException
- org.apache.kafka.common.errors.ApiException
- org.apache.kafka.common.InvalidRecordException
- org.apache.kafka.common.errors.ApiException
- org.apache.kafka.common.KafkaException
- java.lang.RuntimeException
- java.lang.Exception
- org.apache.kafka.common.TopicCollection
- org.apache.kafka.common.TopicCollection.TopicIdCollection
- org.apache.kafka.common.TopicCollection.TopicNameCollection
- org.apache.kafka.common.TopicIdPartition
- org.apache.kafka.common.TopicPartition (implements java.io.Serializable)
- org.apache.kafka.common.TopicPartitionInfo
- org.apache.kafka.common.TopicPartitionReplica (implements java.io.Serializable)
- org.apache.kafka.common.Uuid (implements java.lang.Comparable<T>)
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- org.apache.kafka.common.MessageFormatter (also extends org.apache.kafka.common.Configurable)
- java.io.Closeable
- org.apache.kafka.common.ClusterResourceListener
- org.apache.kafka.common.Configurable
- org.apache.kafka.common.MessageFormatter (also extends java.io.Closeable)
- org.apache.kafka.common.Reconfigurable
- org.apache.kafka.common.KafkaFuture.BaseFunction<A,B>
- org.apache.kafka.common.KafkaFuture.BiConsumer<A,B>
- org.apache.kafka.common.Metric
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
- org.apache.kafka.common.ConsumerGroupState
- org.apache.kafka.common.ElectionType
- org.apache.kafka.common.IsolationLevel
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)