Hierarchy For All Packages

Package Hierarchies:

• org.apache.kafka.clients.consumer,
• org.apache.kafka.clients.producer,
• org.apache.kafka.common,
• org.apache.kafka.common.config,
• org.apache.kafka.common.errors,
• org.apache.kafka.common.serialization,
• org.apache.kafka.connect.connector,
• org.apache.kafka.connect.data,
• org.apache.kafka.connect.errors,
• org.apache.kafka.connect.sink,
• org.apache.kafka.connect.source,
• org.apache.kafka.connect.storage,
• org.apache.kafka.connect.util,
• org.apache.kafka.streams,
• org.apache.kafka.streams.errors,
• org.apache.kafka.streams.kstream,
• org.apache.kafka.streams.processor,
• org.apache.kafka.streams.state

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.streams.StreamsConfig
  • 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.streams.processor.AbstractProcessor<K,V> (implements org.apache.kafka.streams.processor.Processor<K,V>)
  • 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.serialization.ByteBufferDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.ByteBufferSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.common.serialization.BytesDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.BytesSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.common.Cluster
  • org.apache.kafka.common.ClusterResource
  • org.apache.kafka.common.config.Config
  • org.apache.kafka.common.config.ConfigDef
  • org.apache.kafka.common.config.ConfigDef.ConfigKey
  • org.apache.kafka.common.config.ConfigDef.Range (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.ValidList (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.ValidString (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigValue
  • org.apache.kafka.connect.connector.Connector
    • org.apache.kafka.connect.sink.SinkConnector
    • org.apache.kafka.connect.source.SourceConnector
  • org.apache.kafka.connect.util.ConnectorUtils
  • org.apache.kafka.connect.connector.ConnectRecord
    • org.apache.kafka.connect.sink.SinkRecord
    • org.apache.kafka.connect.source.SourceRecord
  • org.apache.kafka.connect.data.ConnectSchema (implements org.apache.kafka.connect.data.Schema)
  • org.apache.kafka.clients.consumer.ConsumerRecord<K,V>
  • org.apache.kafka.clients.consumer.ConsumerRecords<K,V> (implements java.lang.Iterable<T>)
  • org.apache.kafka.streams.processor.ConsumerRecordTimestampExtractor (implements org.apache.kafka.streams.processor.TimestampExtractor)
  • org.apache.kafka.connect.data.Date
  • org.apache.kafka.connect.data.Decimal
  • org.apache.kafka.streams.processor.DefaultPartitionGrouper (implements org.apache.kafka.streams.processor.PartitionGrouper)
  • org.apache.kafka.common.serialization.DoubleDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.DoubleSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.connect.data.Field
  • org.apache.kafka.streams.state.HostInfo
  • 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.streams.KafkaStreams
  • org.apache.kafka.streams.KeyValue<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.clients.consumer.OffsetAndTimestamp
  • org.apache.kafka.common.PartitionInfo
  • org.apache.kafka.clients.producer.ProducerRecord<K,V>
  • org.apache.kafka.streams.state.QueryableStoreTypes
  • org.apache.kafka.clients.producer.RecordMetadata
  • org.apache.kafka.common.config.SaslConfigs
  • org.apache.kafka.connect.data.SchemaAndValue
  • org.apache.kafka.connect.data.SchemaBuilder (implements org.apache.kafka.connect.data.Schema)
  • org.apache.kafka.connect.data.SchemaProjector
  • org.apache.kafka.common.serialization.Serdes
  • org.apache.kafka.common.serialization.Serdes.WrapperSerde<T> (implements org.apache.kafka.common.serialization.Serde<T>)
    • org.apache.kafka.common.serialization.Serdes.ByteArraySerde
    • org.apache.kafka.common.serialization.Serdes.ByteBufferSerde
    • org.apache.kafka.common.serialization.Serdes.BytesSerde
    • org.apache.kafka.common.serialization.Serdes.DoubleSerde
    • org.apache.kafka.common.serialization.Serdes.IntegerSerde
    • org.apache.kafka.common.serialization.Serdes.LongSerde
    • org.apache.kafka.common.serialization.Serdes.StringSerde
  • org.apache.kafka.connect.sink.SinkTask (implements org.apache.kafka.connect.connector.Task)
  • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
  • org.apache.kafka.common.config.SslConfigs
  • org.apache.kafka.streams.state.StateSerdes<K,V>
  • org.apache.kafka.streams.state.Stores
  • org.apache.kafka.streams.state.Stores.StoreFactory
  • org.apache.kafka.streams.state.Stores.ValueFactory<K>
  • org.apache.kafka.streams.StreamsConfig.InternalConfig
  • org.apache.kafka.streams.state.StreamsMetadata
  • org.apache.kafka.connect.storage.StringConverter (implements org.apache.kafka.connect.storage.Converter)
  • 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>)
  • org.apache.kafka.connect.data.Struct
  • org.apache.kafka.streams.processor.TaskId (implements java.lang.Comparable<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.AuthenticationException
              • org.apache.kafka.common.errors.IllegalSaslStateException
              • org.apache.kafka.common.errors.UnsupportedSaslMechanismException
            • org.apache.kafka.common.errors.AuthorizationException
              • org.apache.kafka.common.errors.ClusterAuthorizationException
              • 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.InconsistentGroupProtocolException
            • org.apache.kafka.common.errors.InvalidCommitOffsetSizeException
            • org.apache.kafka.common.errors.InvalidConfigurationException
            • org.apache.kafka.common.errors.InvalidFetchSizeException
            • org.apache.kafka.common.errors.InvalidGroupIdException
            • org.apache.kafka.common.errors.InvalidOffsetException
              • org.apache.kafka.common.errors.OffsetOutOfRangeException
            • org.apache.kafka.common.errors.InvalidPartitionsException
            • org.apache.kafka.common.errors.InvalidReplicaAssignmentException
            • org.apache.kafka.common.errors.InvalidReplicationFactorException
            • org.apache.kafka.common.errors.InvalidRequestException
            • org.apache.kafka.common.errors.InvalidRequiredAcksException
            • org.apache.kafka.common.errors.InvalidSessionTimeoutException
            • org.apache.kafka.common.errors.InvalidTimestampException
            • 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.ReplicaNotAvailableException
            • 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.NotControllerException
              • org.apache.kafka.common.errors.NotCoordinatorForGroupException
              • org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
              • org.apache.kafka.common.errors.NotEnoughReplicasException
              • org.apache.kafka.clients.consumer.RetriableCommitFailedException
              • org.apache.kafka.common.errors.TimeoutException
            • org.apache.kafka.common.errors.TopicExistsException
            • org.apache.kafka.common.errors.UnknownMemberIdException
            • org.apache.kafka.common.errors.UnknownServerException
            • org.apache.kafka.common.errors.UnsupportedForMessageFormatException
            • org.apache.kafka.common.errors.UnsupportedVersionException
          • org.apache.kafka.clients.producer.BufferExhaustedException
          • org.apache.kafka.clients.consumer.CommitFailedException
          • org.apache.kafka.common.config.ConfigException
          • org.apache.kafka.connect.errors.ConnectException
            • org.apache.kafka.connect.errors.AlreadyExistsException
            • org.apache.kafka.connect.errors.DataException
              • org.apache.kafka.connect.errors.SchemaBuilderException
              • org.apache.kafka.connect.errors.SchemaProjectorException
            • org.apache.kafka.connect.errors.IllegalWorkerStateException
            • org.apache.kafka.connect.errors.NotFoundException
            • org.apache.kafka.connect.errors.RetriableException
          • 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.streams.errors.StreamsException
            • org.apache.kafka.streams.errors.InvalidStateStoreException
            • org.apache.kafka.streams.errors.ProcessorStateException
            • org.apache.kafka.streams.errors.TaskAssignmentException
            • org.apache.kafka.streams.errors.TaskIdFormatException
            • org.apache.kafka.streams.errors.TopologyBuilderException
          • org.apache.kafka.common.errors.WakeupException
  • org.apache.kafka.connect.data.Time
  • org.apache.kafka.connect.data.Timestamp
  • org.apache.kafka.common.TopicPartition (implements java.io.Serializable)
  • org.apache.kafka.streams.processor.TopologyBuilder
    • org.apache.kafka.streams.kstream.KStreamBuilder
  • org.apache.kafka.streams.processor.TopologyBuilder.TopicsInfo
  • org.apache.kafka.streams.processor.WallclockTimestampExtractor (implements org.apache.kafka.streams.processor.TimestampExtractor)
  • org.apache.kafka.streams.kstream.Window
  • org.apache.kafka.streams.kstream.Windowed<K>
  • org.apache.kafka.streams.kstream.Windows<W>
    • org.apache.kafka.streams.kstream.JoinWindows
    • org.apache.kafka.streams.kstream.TimeWindows
    • org.apache.kafka.streams.kstream.UnlimitedWindows

Interface Hierarchy

• org.apache.kafka.streams.kstream.Aggregator<K,V,T>
• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.kafka.clients.consumer.Consumer<K,V>
    • org.apache.kafka.common.serialization.Deserializer<T>
    • org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.util.Iterator<E>)
    • org.apache.kafka.clients.producer.Producer<K,V>
    • org.apache.kafka.common.serialization.Serde<T>
    • org.apache.kafka.common.serialization.Serializer<T>
    • org.apache.kafka.streams.state.WindowStoreIterator<E> (also extends java.util.Iterator<E>)
• org.apache.kafka.clients.producer.Callback
• org.apache.kafka.common.ClusterResourceListener
• org.apache.kafka.common.config.ConfigDef.Recommender
• org.apache.kafka.common.config.ConfigDef.Validator
• org.apache.kafka.common.Configurable
  • org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>
  • org.apache.kafka.clients.producer.Partitioner
  • org.apache.kafka.clients.producer.ProducerInterceptor<K,V>
• org.apache.kafka.connect.connector.ConnectorContext
• org.apache.kafka.clients.consumer.ConsumerRebalanceListener
• org.apache.kafka.connect.storage.Converter
• org.apache.kafka.streams.kstream.ForeachAction<K,V>
• org.apache.kafka.streams.kstream.Initializer<T>
• java.util.Iterator<E>
  • org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.io.Closeable)
  • org.apache.kafka.streams.state.WindowStoreIterator<E> (also extends java.io.Closeable)
• org.apache.kafka.streams.KafkaClientSupplier
• org.apache.kafka.streams.kstream.KeyValueMapper<K,V,R>
• org.apache.kafka.streams.kstream.KGroupedStream<K,V>
• org.apache.kafka.streams.kstream.KGroupedTable<K,V>
• org.apache.kafka.streams.kstream.KStream<K,V>
• org.apache.kafka.streams.kstream.KTable<K,V>
• org.apache.kafka.common.Metric
• org.apache.kafka.clients.consumer.OffsetCommitCallback
• org.apache.kafka.connect.storage.OffsetStorageReader
• org.apache.kafka.streams.processor.PartitionGrouper
• org.apache.kafka.streams.kstream.Predicate<K,V>
• org.apache.kafka.streams.processor.Processor<K,V>
• org.apache.kafka.streams.processor.ProcessorContext
• org.apache.kafka.streams.processor.ProcessorSupplier<K,V>
• org.apache.kafka.streams.state.QueryableStoreType<T>
• org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>
  • org.apache.kafka.streams.state.KeyValueStore<K,V> (also extends org.apache.kafka.streams.processor.StateStore)
• org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>
  • org.apache.kafka.streams.state.WindowStore<K,V> (also extends org.apache.kafka.streams.processor.StateStore)
• org.apache.kafka.streams.kstream.Reducer<V>
• org.apache.kafka.streams.state.RocksDBConfigSetter
• org.apache.kafka.connect.data.Schema
• org.apache.kafka.connect.sink.SinkTaskContext
• org.apache.kafka.connect.source.SourceTaskContext
• org.apache.kafka.streams.processor.StateRestoreCallback
• org.apache.kafka.streams.processor.StateStore
  • org.apache.kafka.streams.state.KeyValueStore<K,V> (also extends org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>)
  • org.apache.kafka.streams.state.WindowStore<K,V> (also extends org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>)
• org.apache.kafka.streams.processor.StateStoreSupplier
• org.apache.kafka.streams.state.Stores.InMemoryKeyValueFactory<K,V>
• org.apache.kafka.streams.state.Stores.KeyValueFactory<K,V>
• org.apache.kafka.streams.state.Stores.PersistentKeyValueFactory<K,V>
• org.apache.kafka.streams.processor.StreamPartitioner<K,V>
• org.apache.kafka.streams.StreamsMetrics
• org.apache.kafka.connect.connector.Task
• org.apache.kafka.streams.processor.TimestampExtractor
• org.apache.kafka.streams.kstream.Transformer<K,V,R>
• org.apache.kafka.streams.kstream.TransformerSupplier<K,V,R>
• org.apache.kafka.streams.kstream.ValueJoiner<V1,V2,R>
• org.apache.kafka.streams.kstream.ValueMapper<V1,V2>
• org.apache.kafka.streams.kstream.ValueTransformer<V,R>
• org.apache.kafka.streams.kstream.ValueTransformerSupplier<V,R>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.kafka.clients.consumer.OffsetResetStrategy
    • org.apache.kafka.common.config.ConfigDef.Type
    • org.apache.kafka.common.config.ConfigDef.Importance
    • org.apache.kafka.common.config.ConfigDef.Width
    • org.apache.kafka.connect.data.Schema.Type