Hierarchy For All Packages

Package Hierarchies:

• org.apache.kafka.streams,
• org.apache.kafka.streams.errors,
• org.apache.kafka.streams.kstream,
• org.apache.kafka.streams.processor,
• org.apache.kafka.streams.processor.api,
• org.apache.kafka.streams.processor.assignment,
• org.apache.kafka.streams.processor.assignment.assignors,
• org.apache.kafka.streams.query,
• org.apache.kafka.streams.state

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.common.config.AbstractConfig
    • org.apache.kafka.streams.StreamsConfig
    • org.apache.kafka.streams.TopologyConfig
  • org.apache.kafka.streams.processor.AbstractProcessor<K,V> (implements org.apache.kafka.streams.processor.Processor<K,V>)
  • org.apache.kafka.streams.processor.assignment.AssignmentConfigs
  • org.apache.kafka.streams.kstream.Branched<K,V>
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers (implements org.apache.kafka.streams.state.DslStoreSuppliers)
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers (implements org.apache.kafka.streams.state.DslStoreSuppliers)
  • org.apache.kafka.streams.kstream.Consumed<K,V>
  • org.apache.kafka.streams.processor.api.ContextualFixedKeyProcessor<KIn,VIn,VOut> (implements org.apache.kafka.streams.processor.api.FixedKeyProcessor<KIn,VIn,VOut>)
  • org.apache.kafka.streams.processor.api.ContextualProcessor<KIn,VIn,KOut,VOut> (implements org.apache.kafka.streams.processor.api.Processor<KIn,VIn,KOut,VOut>)
  • org.apache.kafka.streams.errors.DefaultProductionExceptionHandler (implements org.apache.kafka.streams.errors.ProductionExceptionHandler)
  • org.apache.kafka.streams.state.DslKeyValueParams
  • org.apache.kafka.streams.state.DslSessionParams
  • org.apache.kafka.streams.state.DslWindowParams
  • org.apache.kafka.streams.processor.FailOnInvalidTimestamp
  • org.apache.kafka.streams.processor.api.FixedKeyRecord<K,V>
  • org.apache.kafka.streams.kstream.ForeachProcessor<K,V> (implements org.apache.kafka.streams.processor.api.Processor<KIn,VIn,KOut,VOut>)
  • org.apache.kafka.streams.kstream.Grouped<K,V>
  • org.apache.kafka.streams.state.HostInfo
  • org.apache.kafka.streams.processor.api.InternalFixedKeyRecordFactory
  • org.apache.kafka.streams.kstream.Joined<K,V,VO>
  • org.apache.kafka.streams.KafkaStreams (implements java.lang.AutoCloseable)
  • org.apache.kafka.streams.KafkaStreams.CloseOptions
  • org.apache.kafka.streams.processor.assignment.KafkaStreamsAssignment
  • org.apache.kafka.streams.processor.assignment.KafkaStreamsAssignment.AssignedTask
  • org.apache.kafka.streams.query.KeyQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.KeyQueryMetadata
  • org.apache.kafka.streams.KeyValue<K,V>
  • org.apache.kafka.streams.LagInfo
  • org.apache.kafka.streams.errors.LogAndContinueExceptionHandler (implements org.apache.kafka.streams.errors.DeserializationExceptionHandler)
  • org.apache.kafka.streams.errors.LogAndFailExceptionHandler (implements org.apache.kafka.streams.errors.DeserializationExceptionHandler)
  • org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestamp
  • org.apache.kafka.streams.kstream.Materialized<K,V,S>
  • org.apache.kafka.streams.query.MultiVersionedKeyQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.kstream.Named
  • org.apache.kafka.streams.query.Position
  • org.apache.kafka.streams.query.PositionBound
  • org.apache.kafka.streams.kstream.Printed<K,V>
  • org.apache.kafka.streams.processor.assignment.ProcessId (implements java.lang.Comparable<T>)
  • org.apache.kafka.streams.kstream.Produced<K,V>
  • org.apache.kafka.streams.state.QueryableStoreTypes
  • org.apache.kafka.streams.state.QueryableStoreTypes.KeyValueStoreType<K,V>
  • org.apache.kafka.streams.state.QueryableStoreTypes.SessionStoreType<K,V>
  • org.apache.kafka.streams.state.QueryableStoreTypes.WindowStoreType<K,V>
  • org.apache.kafka.streams.query.QueryConfig
  • org.apache.kafka.streams.query.RangeQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.processor.api.Record<K,V>
  • org.apache.kafka.streams.kstream.Repartitioned<K,V>
  • org.apache.kafka.common.serialization.Serdes.WrapperSerde<T> (implements org.apache.kafka.common.serialization.Serde<T>)
    • org.apache.kafka.streams.kstream.WindowedSerdes.SessionWindowedSerde<T>
    • org.apache.kafka.streams.kstream.WindowedSerdes.TimeWindowedSerde<T>
  • org.apache.kafka.streams.kstream.SessionWindowedDeserializer<T> (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.streams.kstream.SessionWindowedSerializer<T> (implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>)
  • org.apache.kafka.streams.kstream.SessionWindows
  • org.apache.kafka.streams.kstream.SlidingWindows
  • org.apache.kafka.streams.query.StateQueryRequest<R>
  • org.apache.kafka.streams.query.StateQueryRequest.InStore
  • org.apache.kafka.streams.query.StateQueryResult<R>
  • org.apache.kafka.streams.state.StateSerdes<K,V>
  • org.apache.kafka.streams.processor.assignment.assignors.StickyTaskAssignor (implements org.apache.kafka.streams.processor.assignment.TaskAssignor)
  • org.apache.kafka.streams.StoreQueryParameters<T>
  • org.apache.kafka.streams.state.Stores
  • org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>
  • org.apache.kafka.streams.StreamsBuilder
  • org.apache.kafka.streams.StreamsConfig.InternalConfig
  • org.apache.kafka.streams.state.StreamsMetadata
  • org.apache.kafka.streams.kstream.TableJoined<K,KO>
  • org.apache.kafka.streams.processor.assignment.TaskAssignmentUtils
  • org.apache.kafka.streams.processor.assignment.TaskAssignmentUtils.RackAwareOptimizationParams
  • org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment
  • org.apache.kafka.streams.processor.TaskId (implements java.lang.Comparable<T>)
  • org.apache.kafka.streams.processor.TaskMetadata
  • org.apache.kafka.streams.processor.ThreadMetadata
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.kafka.common.KafkaException
          • org.apache.kafka.streams.errors.StreamsException
            • org.apache.kafka.streams.errors.BrokerNotFoundException
            • org.apache.kafka.streams.errors.InvalidStateStoreException
              • org.apache.kafka.streams.errors.InvalidStateStorePartitionException
              • org.apache.kafka.streams.errors.StateStoreMigratedException
              • org.apache.kafka.streams.errors.StateStoreNotAvailableException
              • org.apache.kafka.streams.errors.StreamsNotStartedException
              • org.apache.kafka.streams.errors.StreamsRebalancingException
              • org.apache.kafka.streams.errors.StreamsStoppedException
              • org.apache.kafka.streams.errors.UnknownStateStoreException
            • org.apache.kafka.streams.errors.LockException
            • org.apache.kafka.streams.errors.MissingSourceTopicException
            • org.apache.kafka.streams.errors.ProcessorStateException
            • org.apache.kafka.streams.errors.TaskAssignmentException
            • org.apache.kafka.streams.errors.TaskCorruptedException
            • org.apache.kafka.streams.errors.TaskIdFormatException
            • org.apache.kafka.streams.errors.TaskMigratedException
            • org.apache.kafka.streams.errors.TopologyException
            • org.apache.kafka.streams.errors.UnknownTopologyException
  • org.apache.kafka.streams.query.TimestampedKeyQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.query.TimestampedRangeQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.kstream.TimeWindowedDeserializer<T> (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.streams.kstream.TimeWindowedSerializer<T> (implements org.apache.kafka.streams.kstream.internals.WindowedSerializer<T>)
  • org.apache.kafka.streams.processor.To
  • org.apache.kafka.streams.Topology
  • org.apache.kafka.streams.TopologyConfig.TaskConfig
  • org.apache.kafka.streams.processor.UsePartitionTimeOnInvalidTimestamp
  • org.apache.kafka.streams.state.ValueAndTimestamp<V>
  • org.apache.kafka.streams.query.VersionedKeyQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.state.VersionedRecord<V>
  • 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.WindowedSerdes
  • org.apache.kafka.streams.query.WindowKeyQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.streams.query.WindowRangeQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • 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,VAgg>
• org.apache.kafka.streams.processor.assignment.ApplicationState
• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.util.Iterator<E>)
      • org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends java.io.Closeable)
    • org.apache.kafka.streams.state.VersionedRecordIterator<V> (also extends java.util.Iterator<E>)
    • org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends org.apache.kafka.streams.state.KeyValueIterator<K,V>)
• org.apache.kafka.streams.kstream.BranchedKStream<K,V>
• org.apache.kafka.streams.processor.Cancellable
• org.apache.kafka.streams.ClientInstanceIds
• org.apache.kafka.streams.kstream.CogroupedKStream<K,VAgg>
• org.apache.kafka.streams.processor.CommitCallback
• org.apache.kafka.common.Configurable
  • org.apache.kafka.streams.errors.DeserializationExceptionHandler
  • org.apache.kafka.streams.state.DslStoreSuppliers
  • org.apache.kafka.streams.errors.ProductionExceptionHandler
  • org.apache.kafka.streams.processor.assignment.TaskAssignor
• org.apache.kafka.streams.processor.ConnectedStoreProvider
  • org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<KIn,VIn,VOut> (also extends java.util.function.Supplier<T>)
  • org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,VIn,KOut,VOut> (also extends java.util.function.Supplier<T>)
  • org.apache.kafka.streams.processor.ProcessorSupplier<K,V> (also extends java.util.function.Supplier<T>)
  • org.apache.kafka.streams.kstream.TransformerSupplier<K,V,R> (also extends java.util.function.Supplier<T>)
  • org.apache.kafka.streams.kstream.ValueTransformerSupplier<V,VR>
  • org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<K,V,VR> (also extends java.util.function.Supplier<T>)
• org.apache.kafka.streams.kstream.EmitStrategy
• org.apache.kafka.streams.processor.api.FixedKeyProcessor<KIn,VIn,VOut>
• org.apache.kafka.streams.kstream.ForeachAction<K,V>
• org.apache.kafka.streams.kstream.GlobalKTable<K,V>
• org.apache.kafka.streams.kstream.Initializer<VAgg>
• java.util.Iterator<E>
  • org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.io.Closeable)
    • org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends java.io.Closeable)
  • org.apache.kafka.streams.state.VersionedRecordIterator<V> (also extends java.io.Closeable)
• org.apache.kafka.streams.KafkaClientSupplier
• org.apache.kafka.streams.KafkaStreams.StateListener
• org.apache.kafka.streams.processor.assignment.KafkaStreamsState
• org.apache.kafka.streams.kstream.KeyValueMapper<K,V,VR>
• 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.streams.kstream.Merger<K,V>
• org.apache.kafka.streams.kstream.NamedOperation<T>
  • org.apache.kafka.streams.kstream.Suppressed<K>
• org.apache.kafka.streams.kstream.Predicate<K,V>
• org.apache.kafka.streams.processor.api.ProcessingContext
  • org.apache.kafka.streams.processor.api.FixedKeyProcessorContext<KForward,VForward>
  • org.apache.kafka.streams.processor.api.ProcessorContext<KForward,VForward>
• org.apache.kafka.streams.processor.api.Processor<KIn,VIn,KOut,VOut>
• org.apache.kafka.streams.processor.Processor<K,V>
• org.apache.kafka.streams.processor.ProcessorContext
• org.apache.kafka.streams.processor.Punctuator
• org.apache.kafka.streams.query.Query<R>
• org.apache.kafka.streams.state.QueryableStoreType<T>
• org.apache.kafka.streams.query.QueryResult<R>
• 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.TimestampedKeyValueStore<K,V>
    • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.TimestampedBytesStore)
  • org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>
  • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.KeyValueStore<K,V>, org.apache.kafka.streams.state.TimestampedBytesStore)
• org.apache.kafka.streams.state.ReadOnlySessionStore<K,AGG>
  • org.apache.kafka.streams.state.SessionStore<K,AGG> (also extends org.apache.kafka.streams.processor.StateStore)
• org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>
  • org.apache.kafka.streams.state.TimestampedWindowStore<K,V>
  • org.apache.kafka.streams.state.WindowStore<K,V> (also extends org.apache.kafka.streams.processor.StateStore)
    • org.apache.kafka.streams.state.TimestampedWindowStore<K,V>
• org.apache.kafka.streams.processor.RecordContext
• org.apache.kafka.streams.processor.api.RecordMetadata
• org.apache.kafka.streams.kstream.Reducer<V>
• org.apache.kafka.streams.state.RocksDBConfigSetter
• org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,V>
• org.apache.kafka.streams.kstream.SessionWindowedKStream<K,V>
• org.apache.kafka.streams.processor.StandbyUpdateListener
• org.apache.kafka.streams.processor.StateRestoreCallback
  • org.apache.kafka.streams.processor.BatchingStateRestoreCallback
• org.apache.kafka.streams.processor.StateRestoreListener
• 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.TimestampedKeyValueStore<K,V>
    • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.TimestampedBytesStore)
  • org.apache.kafka.streams.state.SessionStore<K,AGG> (also extends org.apache.kafka.streams.state.ReadOnlySessionStore<K,AGG>)
  • org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>
  • org.apache.kafka.streams.state.TimestampedWindowStore<K,V>
  • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.KeyValueStore<K,V>, org.apache.kafka.streams.state.TimestampedBytesStore)
  • org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>
  • org.apache.kafka.streams.state.WindowStore<K,V> (also extends org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>)
    • org.apache.kafka.streams.state.TimestampedWindowStore<K,V>
• org.apache.kafka.streams.processor.StateStoreContext
• org.apache.kafka.streams.state.StoreBuilder<T>
• org.apache.kafka.streams.state.StoreSupplier<T>
  • org.apache.kafka.streams.state.KeyValueBytesStoreSupplier
    • org.apache.kafka.streams.state.VersionedBytesStoreSupplier
  • org.apache.kafka.streams.state.SessionBytesStoreSupplier
  • org.apache.kafka.streams.state.VersionedBytesStoreSupplier
  • org.apache.kafka.streams.state.WindowBytesStoreSupplier
• org.apache.kafka.streams.processor.StreamPartitioner<K,V>
• org.apache.kafka.streams.StreamsMetadata
• org.apache.kafka.streams.StreamsMetrics
• org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler
• java.util.function.Supplier<T>
  • org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<KIn,VIn,VOut> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
  • org.apache.kafka.streams.processor.api.ProcessorSupplier<KIn,VIn,KOut,VOut> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
  • org.apache.kafka.streams.processor.ProcessorSupplier<K,V> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
  • org.apache.kafka.streams.kstream.TransformerSupplier<K,V,R> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
  • org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<K,V,VR> (also extends org.apache.kafka.streams.processor.ConnectedStoreProvider)
• org.apache.kafka.streams.kstream.Suppressed.BufferConfig<BC>
  • org.apache.kafka.streams.kstream.Suppressed.EagerBufferConfig
  • org.apache.kafka.streams.kstream.Suppressed.StrictBufferConfig
• org.apache.kafka.streams.processor.assignment.TaskAssignmentUtils.MoveStandbyTaskPredicate
• org.apache.kafka.streams.processor.assignment.TaskInfo
• org.apache.kafka.streams.TaskMetadata
• org.apache.kafka.streams.processor.assignment.TaskTopicPartition
• org.apache.kafka.streams.ThreadMetadata
• org.apache.kafka.streams.state.TimestampedBytesStore
  • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.KeyValueStore<K,V>)
• org.apache.kafka.streams.processor.TimestampExtractor
• org.apache.kafka.streams.kstream.TimeWindowedCogroupedKStream<K,V>
• org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>
• org.apache.kafka.streams.processor.TopicNameExtractor<K,V>
• org.apache.kafka.streams.TopologyDescription
• org.apache.kafka.streams.TopologyDescription.GlobalStore
• org.apache.kafka.streams.TopologyDescription.Node
  • org.apache.kafka.streams.TopologyDescription.Processor
  • org.apache.kafka.streams.TopologyDescription.Sink
  • org.apache.kafka.streams.TopologyDescription.Source
• org.apache.kafka.streams.TopologyDescription.Subtopology
• org.apache.kafka.streams.kstream.Transformer<K,V,R>
• org.apache.kafka.streams.kstream.ValueJoiner<V1,V2,VR>
• org.apache.kafka.streams.kstream.ValueJoinerWithKey<K1,V1,V2,VR>
• org.apache.kafka.streams.kstream.ValueMapper<V,VR>
• org.apache.kafka.streams.kstream.ValueMapperWithKey<K,V,VR>
• org.apache.kafka.streams.kstream.ValueTransformer<V,VR>
• org.apache.kafka.streams.kstream.ValueTransformerWithKey<K,V,VR>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
    • org.apache.kafka.streams.kstream.EmitStrategy.StrategyType
    • org.apache.kafka.streams.query.FailureReason
    • org.apache.kafka.streams.KafkaStreams.State
    • org.apache.kafka.streams.processor.assignment.KafkaStreamsAssignment.AssignedTask.Type
    • org.apache.kafka.streams.kstream.Materialized.StoreType (implements org.apache.kafka.streams.state.DslStoreSuppliers)
    • org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
    • org.apache.kafka.streams.processor.PunctuationType
    • org.apache.kafka.streams.query.ResultOrder
    • org.apache.kafka.streams.processor.StandbyUpdateListener.SuspendReason
    • org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse
    • org.apache.kafka.streams.processor.assignment.TaskAssignor.AssignmentError
    • org.apache.kafka.streams.Topology.AutoOffsetReset