Hierarchy For All Packages

Package Hierarchies:

• org.apache.kafka.clients.consumer,
• org.apache.kafka.clients.producer,
• org.apache.kafka.common,
• org.apache.kafka.common.errors,
• org.apache.kafka.common.serialization

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.common.config.AbstractConfig
    • org.apache.kafka.clients.consumer.ConsumerConfig
    • org.apache.kafka.clients.producer.ProducerConfig
  • org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor (implements org.apache.kafka.clients.consumer.internals.PartitionAssignor)
    • org.apache.kafka.clients.consumer.RangeAssignor
    • org.apache.kafka.clients.consumer.RoundRobinAssignor
  • org.apache.kafka.common.serialization.ByteArrayDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.ByteArraySerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.common.Cluster
  • org.apache.kafka.clients.consumer.ConsumerRecord<K,V>
  • org.apache.kafka.clients.consumer.ConsumerRecords<K,V> (implements java.lang.Iterable<T>)
  • org.apache.kafka.common.serialization.IntegerDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.IntegerSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.clients.consumer.KafkaConsumer<K,V> (implements org.apache.kafka.clients.consumer.Consumer<K,V>)
  • org.apache.kafka.clients.producer.KafkaProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.apache.kafka.common.serialization.LongDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.LongSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.common.MetricName
  • org.apache.kafka.clients.consumer.MockConsumer<K,V> (implements org.apache.kafka.clients.consumer.Consumer<K,V>)
  • org.apache.kafka.clients.producer.MockProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.apache.kafka.common.Node
  • org.apache.kafka.clients.consumer.OffsetAndMetadata (implements java.io.Serializable)
  • org.apache.kafka.common.PartitionInfo
  • org.apache.kafka.clients.producer.ProducerRecord<K,V>
  • org.apache.kafka.clients.producer.RecordMetadata
  • org.apache.kafka.common.serialization.StringDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.StringSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • 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.errors.AuthorizationException
              • org.apache.kafka.common.errors.GroupAuthorizationException
              • org.apache.kafka.common.errors.TopicAuthorizationException
            • org.apache.kafka.common.errors.BrokerNotAvailableException
            • org.apache.kafka.common.errors.ControllerMovedException
            • org.apache.kafka.common.errors.IllegalGenerationException
            • org.apache.kafka.common.errors.InvalidRequiredAcksException
            • org.apache.kafka.common.errors.InvalidTopicException
            • org.apache.kafka.common.errors.OffsetMetadataTooLarge
            • org.apache.kafka.common.errors.RebalanceInProgressException
            • org.apache.kafka.common.errors.RecordBatchTooLargeException
            • org.apache.kafka.common.errors.RecordTooLargeException
            • org.apache.kafka.common.errors.RetriableException
              • org.apache.kafka.common.errors.CorruptRecordException
              • org.apache.kafka.common.errors.DisconnectException
              • org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException
              • org.apache.kafka.common.errors.GroupLoadInProgressException
              • org.apache.kafka.common.errors.InvalidMetadataException
                • org.apache.kafka.common.errors.LeaderNotAvailableException
                • org.apache.kafka.common.errors.NetworkException
                • org.apache.kafka.common.errors.NotLeaderForPartitionException
                • org.apache.kafka.common.errors.UnknownTopicOrPartitionException
              • org.apache.kafka.common.errors.NotCoordinatorForGroupException
              • org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
              • org.apache.kafka.common.errors.NotEnoughReplicasException
              • org.apache.kafka.common.errors.TimeoutException
            • org.apache.kafka.common.errors.UnknownMemberIdException
            • org.apache.kafka.common.errors.UnknownServerException
          • org.apache.kafka.clients.producer.BufferExhaustedException
          • org.apache.kafka.clients.consumer.CommitFailedException
          • org.apache.kafka.common.errors.InterruptException
          • org.apache.kafka.clients.consumer.InvalidOffsetException
            • org.apache.kafka.clients.consumer.NoOffsetForPartitionException
            • org.apache.kafka.clients.consumer.OffsetOutOfRangeException
          • org.apache.kafka.common.errors.SerializationException
          • org.apache.kafka.common.errors.WakeupException
  • org.apache.kafka.common.TopicPartition (implements java.io.Serializable)

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.kafka.clients.consumer.Consumer<K,V>
    • org.apache.kafka.common.serialization.Deserializer<T>
    • org.apache.kafka.clients.producer.Producer<K,V>
    • org.apache.kafka.common.serialization.Serializer<T>
• org.apache.kafka.clients.producer.Callback
• org.apache.kafka.common.Configurable
  • org.apache.kafka.clients.producer.Partitioner
• org.apache.kafka.clients.consumer.ConsumerRebalanceListener
• org.apache.kafka.common.Metric
• org.apache.kafka.clients.consumer.OffsetCommitCallback

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.kafka.clients.consumer.OffsetResetStrategy