Hierarchy For All Packages

Package Hierarchies:

• org.apache.kafka.clients.admin,
• org.apache.kafka.clients.consumer,
• org.apache.kafka.clients.producer,
• org.apache.kafka.common,
• org.apache.kafka.common.acl,
• org.apache.kafka.common.annotation,
• org.apache.kafka.common.config,
• org.apache.kafka.common.config.provider,
• org.apache.kafka.common.errors,
• org.apache.kafka.common.header,
• org.apache.kafka.common.metrics,
• org.apache.kafka.common.metrics.stats,
• org.apache.kafka.common.quota,
• org.apache.kafka.common.resource,
• org.apache.kafka.common.security.auth,
• org.apache.kafka.common.security.oauthbearer,
• org.apache.kafka.common.security.oauthbearer.secured,
• org.apache.kafka.common.security.plain,
• org.apache.kafka.common.security.scram,
• org.apache.kafka.common.security.token.delegation,
• org.apache.kafka.common.serialization,
• org.apache.kafka.connect.components,
• org.apache.kafka.connect.connector,
• org.apache.kafka.connect.connector.policy,
• org.apache.kafka.connect.data,
• org.apache.kafka.connect.errors,
• org.apache.kafka.connect.header,
• org.apache.kafka.connect.health,
• org.apache.kafka.connect.mirror,
• org.apache.kafka.connect.rest,
• org.apache.kafka.connect.sink,
• org.apache.kafka.connect.source,
• org.apache.kafka.connect.storage,
• org.apache.kafka.connect.tools,
• org.apache.kafka.connect.transforms,
• org.apache.kafka.connect.transforms.predicates,
• org.apache.kafka.connect.util,
• org.apache.kafka.server.authorizer,
• org.apache.kafka.server.log.remote.storage,
• org.apache.kafka.server.policy,
• org.apache.kafka.server.quota,
• 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.query,
• org.apache.kafka.streams.state,
• org.apache.kafka.streams.test,
• org.apache.kafka.tools.api

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.clients.admin.AbortTransactionResult
  • org.apache.kafka.clients.admin.AbortTransactionSpec
  • org.apache.kafka.common.config.AbstractConfig
    • org.apache.kafka.clients.admin.AdminClientConfig
    • org.apache.kafka.clients.consumer.ConsumerConfig
    • org.apache.kafka.connect.storage.ConverterConfig
      • org.apache.kafka.connect.storage.StringConverterConfig
    • org.apache.kafka.connect.mirror.MirrorClientConfig
    • org.apache.kafka.clients.producer.ProducerConfig
    • org.apache.kafka.streams.StreamsConfig
    • org.apache.kafka.streams.TopologyConfig
  • org.apache.kafka.clients.admin.AbstractOptions<T>
    • org.apache.kafka.clients.admin.AbortTransactionOptions
    • org.apache.kafka.clients.admin.AlterClientQuotasOptions
    • org.apache.kafka.clients.admin.AlterConfigsOptions
    • org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions
    • org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions
    • org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions
    • org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions
    • org.apache.kafka.clients.admin.CreateAclsOptions
    • org.apache.kafka.clients.admin.CreateDelegationTokenOptions
    • org.apache.kafka.clients.admin.CreatePartitionsOptions
    • org.apache.kafka.clients.admin.CreateTopicsOptions
    • org.apache.kafka.clients.admin.DeleteAclsOptions
    • org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsOptions
    • org.apache.kafka.clients.admin.DeleteConsumerGroupsOptions
    • org.apache.kafka.clients.admin.DeleteRecordsOptions
    • org.apache.kafka.clients.admin.DeleteTopicsOptions
    • org.apache.kafka.clients.admin.DescribeAclsOptions
    • org.apache.kafka.clients.admin.DescribeClientQuotasOptions
    • org.apache.kafka.clients.admin.DescribeClusterOptions
    • org.apache.kafka.clients.admin.DescribeConfigsOptions
    • org.apache.kafka.clients.admin.DescribeConsumerGroupsOptions
    • org.apache.kafka.clients.admin.DescribeDelegationTokenOptions
    • org.apache.kafka.clients.admin.DescribeFeaturesOptions
    • org.apache.kafka.clients.admin.DescribeLogDirsOptions
    • org.apache.kafka.clients.admin.DescribeMetadataQuorumOptions
    • org.apache.kafka.clients.admin.DescribeProducersOptions
    • org.apache.kafka.clients.admin.DescribeReplicaLogDirsOptions
    • org.apache.kafka.clients.admin.DescribeTopicsOptions
    • org.apache.kafka.clients.admin.DescribeTransactionsOptions
    • org.apache.kafka.clients.admin.DescribeUserScramCredentialsOptions
    • org.apache.kafka.clients.admin.ElectLeadersOptions
    • org.apache.kafka.clients.admin.ExpireDelegationTokenOptions
    • org.apache.kafka.clients.admin.FenceProducersOptions
    • org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions
    • org.apache.kafka.clients.admin.ListConsumerGroupsOptions
    • org.apache.kafka.clients.admin.ListOffsetsOptions
    • org.apache.kafka.clients.admin.ListPartitionReassignmentsOptions
    • org.apache.kafka.clients.admin.ListTopicsOptions
    • org.apache.kafka.clients.admin.ListTransactionsOptions
    • org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupOptions
    • org.apache.kafka.clients.admin.RenewDelegationTokenOptions
    • org.apache.kafka.clients.admin.UnregisterBrokerOptions
    • org.apache.kafka.clients.admin.UpdateFeaturesOptions
  • org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor (implements org.apache.kafka.clients.consumer.ConsumerPartitionAssignor)
    • org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor
      • org.apache.kafka.clients.consumer.CooperativeStickyAssignor
      • org.apache.kafka.clients.consumer.StickyAssignor
    • 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.connect.health.AbstractState
    • org.apache.kafka.connect.health.ConnectorState
    • org.apache.kafka.connect.health.TaskState
  • org.apache.kafka.common.acl.AccessControlEntry
  • org.apache.kafka.common.acl.AccessControlEntryFilter
  • org.apache.kafka.common.acl.AclBinding
  • org.apache.kafka.common.acl.AclBindingFilter
  • org.apache.kafka.server.authorizer.AclCreateResult
  • org.apache.kafka.server.authorizer.AclDeleteResult
  • org.apache.kafka.server.authorizer.AclDeleteResult.AclBindingDeleteResult
  • org.apache.kafka.server.authorizer.Action
  • org.apache.kafka.clients.admin.AdminClient (implements org.apache.kafka.clients.admin.Admin)
    • org.apache.kafka.clients.admin.KafkaAdminClient
  • org.apache.kafka.clients.admin.AlterClientQuotasResult
  • org.apache.kafka.clients.admin.AlterConfigOp
  • org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata
  • org.apache.kafka.clients.admin.AlterConfigsResult
  • org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult
  • org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult
  • org.apache.kafka.clients.admin.AlterReplicaLogDirsResult
  • org.apache.kafka.clients.admin.AlterUserScramCredentialsResult
  • org.apache.kafka.common.serialization.BooleanDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.BooleanSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.streams.kstream.Branched<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.connect.mirror.Checkpoint
  • org.apache.kafka.common.quota.ClientQuotaAlteration
  • org.apache.kafka.common.quota.ClientQuotaAlteration.Op
  • org.apache.kafka.common.quota.ClientQuotaEntity
  • org.apache.kafka.common.quota.ClientQuotaFilter
  • org.apache.kafka.common.quota.ClientQuotaFilterComponent
  • org.apache.kafka.common.Cluster
  • org.apache.kafka.common.ClusterResource
  • org.apache.kafka.common.metrics.CompoundStat.NamedMeasurable
  • org.apache.kafka.clients.admin.Config
  • org.apache.kafka.common.config.Config
  • org.apache.kafka.common.config.ConfigData
  • org.apache.kafka.common.config.ConfigDef
  • org.apache.kafka.common.config.ConfigDef.CaseInsensitiveValidString (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.CompositeValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.ConfigKey
  • org.apache.kafka.common.config.ConfigDef.LambdaValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.ListSize (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.NonEmptyString (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.NonEmptyStringWithoutControlChars (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • org.apache.kafka.common.config.ConfigDef.NonNullValidator (implements org.apache.kafka.common.config.ConfigDef.Validator)
  • 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.clients.admin.ConfigEntry
  • org.apache.kafka.clients.admin.ConfigEntry.ConfigSynonym
  • org.apache.kafka.common.config.ConfigResource
  • org.apache.kafka.common.config.ConfigTransformer
  • org.apache.kafka.common.config.ConfigTransformerResult
  • org.apache.kafka.common.config.ConfigValue
  • org.apache.kafka.connect.header.ConnectHeaders (implements org.apache.kafka.connect.header.Headers)
  • org.apache.kafka.connect.connector.Connector (implements org.apache.kafka.connect.components.Versioned)
    • org.apache.kafka.connect.tools.MockConnector
    • org.apache.kafka.connect.sink.SinkConnector
      • org.apache.kafka.connect.tools.MockSinkConnector
      • org.apache.kafka.connect.tools.VerifiableSinkConnector
    • org.apache.kafka.connect.source.SourceConnector
      • org.apache.kafka.connect.tools.MockSourceConnector
      • org.apache.kafka.connect.tools.SchemaSourceConnector
      • org.apache.kafka.connect.tools.VerifiableSourceConnector
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest
  • org.apache.kafka.connect.health.ConnectorHealth
  • org.apache.kafka.connect.util.ConnectorUtils
  • org.apache.kafka.connect.connector.ConnectRecord<R>
    • 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.streams.kstream.Consumed<K,V>
  • org.apache.kafka.clients.admin.ConsumerGroupDescription
  • org.apache.kafka.clients.admin.ConsumerGroupListing
  • org.apache.kafka.clients.consumer.ConsumerGroupMetadata
  • org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment
  • org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupAssignment
  • org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.GroupSubscription
  • org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Subscription
  • 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.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.clients.admin.CreateAclsResult
  • org.apache.kafka.clients.admin.CreateDelegationTokenResult
  • org.apache.kafka.clients.admin.CreatePartitionsResult
  • org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata
  • org.apache.kafka.clients.admin.CreateTopicsResult
  • org.apache.kafka.clients.admin.CreateTopicsResult.TopicMetadataAndConfig
  • org.apache.kafka.common.metrics.stats.CumulativeSum (implements org.apache.kafka.common.metrics.MeasurableStat)
    • org.apache.kafka.common.metrics.stats.CumulativeCount
  • org.apache.kafka.connect.data.Date
  • org.apache.kafka.connect.data.Decimal
  • org.apache.kafka.streams.errors.DefaultProductionExceptionHandler (implements org.apache.kafka.streams.errors.ProductionExceptionHandler)
  • org.apache.kafka.connect.mirror.DefaultReplicationPolicy (implements org.apache.kafka.common.Configurable, org.apache.kafka.connect.mirror.ReplicationPolicy)
    • org.apache.kafka.connect.mirror.IdentityReplicationPolicy
  • org.apache.kafka.common.security.token.delegation.DelegationToken
  • org.apache.kafka.clients.admin.DeleteAclsResult
  • org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult
  • org.apache.kafka.clients.admin.DeleteAclsResult.FilterResults
  • org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsResult
  • org.apache.kafka.clients.admin.DeleteConsumerGroupsResult
  • org.apache.kafka.clients.admin.DeletedRecords
  • org.apache.kafka.clients.admin.DeleteRecordsResult
  • org.apache.kafka.clients.admin.DeleteTopicsResult
  • org.apache.kafka.clients.admin.DescribeAclsResult
  • org.apache.kafka.clients.admin.DescribeClientQuotasResult
  • org.apache.kafka.clients.admin.DescribeClusterResult
  • org.apache.kafka.clients.admin.DescribeConfigsResult
  • org.apache.kafka.clients.admin.DescribeConsumerGroupsResult
  • org.apache.kafka.clients.admin.DescribeDelegationTokenResult
  • org.apache.kafka.clients.admin.DescribeFeaturesResult
  • org.apache.kafka.clients.admin.DescribeLogDirsResult
  • org.apache.kafka.clients.admin.DescribeMetadataQuorumResult
  • org.apache.kafka.clients.admin.DescribeProducersResult
  • org.apache.kafka.clients.admin.DescribeProducersResult.PartitionProducerState
  • org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult
  • org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo
  • org.apache.kafka.clients.admin.DescribeTopicsResult
  • org.apache.kafka.clients.admin.DescribeTransactionsResult
  • org.apache.kafka.clients.admin.DescribeUserScramCredentialsResult
  • org.apache.kafka.common.config.provider.DirectoryConfigProvider (implements org.apache.kafka.common.config.provider.ConfigProvider)
  • 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.clients.admin.ElectLeadersResult
  • org.apache.kafka.common.Endpoint
  • org.apache.kafka.common.config.provider.EnvVarConfigProvider (implements org.apache.kafka.common.config.provider.ConfigProvider)
  • org.apache.kafka.clients.admin.ExpireDelegationTokenResult
  • org.apache.kafka.streams.processor.FailOnInvalidTimestamp
  • org.apache.kafka.clients.admin.FeatureMetadata
  • org.apache.kafka.clients.admin.FeatureUpdate
  • org.apache.kafka.clients.admin.FenceProducersResult
  • org.apache.kafka.connect.data.Field
  • org.apache.kafka.common.config.provider.FileConfigProvider (implements org.apache.kafka.common.config.provider.ConfigProvider)
  • org.apache.kafka.clients.admin.FinalizedVersionRange
  • org.apache.kafka.streams.processor.api.FixedKeyRecord<K,V>
  • org.apache.kafka.common.serialization.FloatDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.FloatSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.streams.kstream.ForeachProcessor<K,V> (implements org.apache.kafka.streams.processor.api.Processor<KIn,VIn,KOut,VOut>)
  • org.apache.kafka.clients.admin.ForwardingAdmin (implements org.apache.kafka.clients.admin.Admin)
  • org.apache.kafka.common.metrics.stats.Frequency
  • org.apache.kafka.streams.kstream.Grouped<K,V>
  • org.apache.kafka.connect.mirror.Heartbeat
  • org.apache.kafka.common.metrics.stats.Histogram
  • org.apache.kafka.common.metrics.stats.Histogram.ConstantBinScheme (implements org.apache.kafka.common.metrics.stats.Histogram.BinScheme)
  • org.apache.kafka.common.metrics.stats.Histogram.LinearBinScheme (implements org.apache.kafka.common.metrics.stats.Histogram.BinScheme)
  • 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.common.annotation.InterfaceStability
  • org.apache.kafka.streams.processor.api.InternalFixedKeyRecordFactory
  • org.apache.kafka.common.metrics.JmxReporter (implements org.apache.kafka.common.metrics.MetricsReporter)
  • org.apache.kafka.streams.kstream.Joined<K,V,VO>
  • org.apache.kafka.clients.consumer.KafkaConsumer<K,V> (implements org.apache.kafka.clients.consumer.Consumer<K,V>)
  • 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.metrics.KafkaMetric (implements org.apache.kafka.common.Metric)
  • org.apache.kafka.common.metrics.KafkaMetricsContext (implements org.apache.kafka.common.metrics.MetricsContext)
  • org.apache.kafka.common.security.auth.KafkaPrincipal (implements java.security.Principal)
  • org.apache.kafka.clients.producer.KafkaProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.apache.kafka.streams.KafkaStreams (implements java.lang.AutoCloseable)
  • org.apache.kafka.streams.KafkaStreams.CloseOptions
  • 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.clients.admin.ListConsumerGroupOffsetsResult
  • org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec
  • org.apache.kafka.clients.admin.ListConsumerGroupsResult
  • org.apache.kafka.common.serialization.ListDeserializer<Inner> (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.clients.admin.ListOffsetsResult
  • org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo
  • org.apache.kafka.clients.admin.ListPartitionReassignmentsResult
  • org.apache.kafka.common.serialization.ListSerializer<Inner> (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.clients.admin.ListTopicsResult
  • org.apache.kafka.clients.admin.ListTransactionsResult
  • 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.clients.admin.LogDirDescription
  • org.apache.kafka.common.config.LogLevelConfig
  • org.apache.kafka.server.log.remote.storage.LogSegmentData
  • 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.streams.kstream.Materialized<K,V,S>
  • org.apache.kafka.clients.admin.MemberAssignment
  • org.apache.kafka.clients.admin.MemberDescription
  • org.apache.kafka.clients.admin.MemberToRemove
  • org.apache.kafka.common.metrics.stats.Meter (implements org.apache.kafka.common.metrics.CompoundStat)
  • org.apache.kafka.common.metrics.MetricConfig
  • org.apache.kafka.common.MetricName
  • org.apache.kafka.common.MetricNameTemplate
  • org.apache.kafka.common.metrics.Metrics (implements java.io.Closeable)
  • org.apache.kafka.connect.mirror.MirrorClient (implements java.lang.AutoCloseable)
  • org.apache.kafka.clients.consumer.MockConsumer<K,V> (implements org.apache.kafka.clients.consumer.Consumer<K,V>)
  • org.apache.kafka.streams.processor.api.MockProcessorContext<KForward,VForward> (implements org.apache.kafka.streams.processor.api.ProcessorContext<KForward,VForward>, org.apache.kafka.streams.processor.internals.RecordCollector.Supplier)
  • org.apache.kafka.streams.processor.MockProcessorContext (implements org.apache.kafka.streams.processor.ProcessorContext, org.apache.kafka.streams.processor.internals.RecordCollector.Supplier)
  • org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedForward<K,V>
  • org.apache.kafka.streams.processor.MockProcessorContext.CapturedForward
  • org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedPunctuator
  • org.apache.kafka.streams.processor.MockProcessorContext.CapturedPunctuator
  • org.apache.kafka.clients.producer.MockProducer<K,V> (implements org.apache.kafka.clients.producer.Producer<K,V>)
  • org.apache.kafka.streams.kstream.Named
  • org.apache.kafka.clients.admin.NewPartitionReassignment
  • org.apache.kafka.clients.admin.NewPartitions
  • org.apache.kafka.clients.admin.NewTopic
  • org.apache.kafka.common.Node
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerExtensionsValidatorCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
    • org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule (implements javax.security.auth.spi.LoginModule)
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerTokenCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler (implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler)
    • org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler
  • org.apache.kafka.clients.consumer.OffsetAndMetadata (implements java.io.Serializable)
  • org.apache.kafka.clients.consumer.OffsetAndTimestamp
  • org.apache.kafka.clients.admin.OffsetSpec
    • org.apache.kafka.clients.admin.OffsetSpec.EarliestSpec
    • org.apache.kafka.clients.admin.OffsetSpec.LatestSpec
    • org.apache.kafka.clients.admin.OffsetSpec.MaxTimestampSpec
    • org.apache.kafka.clients.admin.OffsetSpec.TimestampSpec
  • org.apache.kafka.common.PartitionInfo
  • org.apache.kafka.clients.admin.PartitionReassignment
  • org.apache.kafka.common.metrics.stats.Percentile
  • org.apache.kafka.common.security.plain.PlainAuthenticateCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.common.security.plain.PlainLoginModule (implements javax.security.auth.spi.LoginModule)
  • org.apache.kafka.common.security.auth.PlaintextAuthenticationContext (implements org.apache.kafka.common.security.auth.AuthenticationContext)
  • org.apache.kafka.streams.query.Position
  • org.apache.kafka.streams.query.PositionBound
  • org.apache.kafka.streams.kstream.Printed<K,V>
  • org.apache.kafka.streams.kstream.Produced<K,V>
  • org.apache.kafka.clients.producer.ProducerRecord<K,V>
  • org.apache.kafka.clients.admin.ProducerState
  • 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.clients.admin.QuorumInfo
  • org.apache.kafka.clients.admin.QuorumInfo.ReplicaState
  • org.apache.kafka.common.metrics.Quota
  • org.apache.kafka.streams.query.RangeQuery<K,V> (implements org.apache.kafka.streams.query.Query<R>)
  • org.apache.kafka.common.metrics.stats.Rate (implements org.apache.kafka.common.metrics.MeasurableStat)
    • org.apache.kafka.common.metrics.stats.SimpleRate
  • org.apache.kafka.streams.processor.api.Record<K,V>
  • org.apache.kafka.clients.producer.RecordMetadata
  • org.apache.kafka.clients.admin.RecordsToDelete
  • org.apache.kafka.connect.mirror.RemoteClusterUtils
  • org.apache.kafka.server.log.remote.storage.RemoteLogMetadata
    • org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata
    • org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate
    • org.apache.kafka.server.log.remote.storage.RemotePartitionDeleteMetadata
  • org.apache.kafka.server.log.remote.storage.RemoteLogSegmentId
  • org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata.CustomMetadata
  • org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
  • org.apache.kafka.clients.admin.RemoveMembersFromConsumerGroupResult
  • org.apache.kafka.clients.admin.RenewDelegationTokenResult
  • org.apache.kafka.streams.kstream.Repartitioned<K,V>
  • org.apache.kafka.clients.admin.ReplicaInfo
  • org.apache.kafka.common.resource.Resource
  • org.apache.kafka.common.resource.ResourcePattern
  • org.apache.kafka.common.resource.ResourcePatternFilter
  • org.apache.kafka.clients.producer.RoundRobinPartitioner (implements org.apache.kafka.clients.producer.Partitioner)
  • org.apache.kafka.common.metrics.stats.SampledStat (implements org.apache.kafka.common.metrics.MeasurableStat)
    • org.apache.kafka.common.metrics.stats.Avg
    • org.apache.kafka.common.metrics.stats.Frequencies (implements org.apache.kafka.common.metrics.CompoundStat)
    • org.apache.kafka.common.metrics.stats.Max
    • org.apache.kafka.common.metrics.stats.Min
    • org.apache.kafka.common.metrics.stats.Percentiles (implements org.apache.kafka.common.metrics.CompoundStat)
    • org.apache.kafka.common.metrics.stats.WindowedSum
      • org.apache.kafka.common.metrics.stats.WindowedCount
  • org.apache.kafka.common.metrics.stats.SampledStat.Sample
  • org.apache.kafka.common.security.auth.SaslAuthenticationContext (implements org.apache.kafka.common.security.auth.AuthenticationContext)
  • org.apache.kafka.common.config.SaslConfigs
  • org.apache.kafka.common.security.auth.SaslExtensions
  • org.apache.kafka.common.security.auth.SaslExtensionsCallback (implements javax.security.auth.callback.Callback)
  • 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.security.scram.ScramCredential
  • org.apache.kafka.common.security.scram.ScramCredentialCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.clients.admin.ScramCredentialInfo
  • org.apache.kafka.common.security.scram.ScramExtensionsCallback (implements javax.security.auth.callback.Callback)
  • org.apache.kafka.common.security.scram.ScramLoginModule (implements javax.security.auth.spi.LoginModule)
  • org.apache.kafka.common.config.SecurityConfig
  • org.apache.kafka.common.metrics.Sensor
  • 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.BooleanSerde
    • 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.FloatSerde
    • org.apache.kafka.common.serialization.Serdes.IntegerSerde
    • org.apache.kafka.common.serialization.Serdes.ListSerde<Inner>
    • org.apache.kafka.common.serialization.Serdes.LongSerde
    • org.apache.kafka.common.serialization.Serdes.ShortSerde
    • org.apache.kafka.common.serialization.Serdes.StringSerde
    • org.apache.kafka.common.serialization.Serdes.UUIDSerde
    • org.apache.kafka.common.serialization.Serdes.VoidSerde
    • 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.common.serialization.ShortDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.ShortSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.connect.storage.SimpleHeaderConverter (implements org.apache.kafka.connect.storage.HeaderConverter, org.apache.kafka.connect.components.Versioned)
  • org.apache.kafka.connect.sink.SinkTask (implements org.apache.kafka.connect.connector.Task)
    • org.apache.kafka.connect.tools.MockSinkTask
    • org.apache.kafka.connect.tools.VerifiableSinkTask
  • org.apache.kafka.streams.kstream.SlidingWindows
  • org.apache.kafka.connect.mirror.SourceAndTarget
  • org.apache.kafka.connect.source.SourceTask (implements org.apache.kafka.connect.connector.Task)
    • org.apache.kafka.connect.tools.MockSourceTask
    • org.apache.kafka.connect.tools.SchemaSourceTask
    • org.apache.kafka.connect.tools.VerifiableSourceTask
  • org.apache.kafka.common.security.auth.SslAuthenticationContext (implements org.apache.kafka.common.security.auth.AuthenticationContext)
  • org.apache.kafka.common.config.SslConfigs
  • 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.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.connect.storage.StringConverter (implements org.apache.kafka.connect.storage.Converter, org.apache.kafka.connect.storage.HeaderConverter, org.apache.kafka.connect.components.Versioned)
  • 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.clients.admin.SupportedVersionRange
  • org.apache.kafka.streams.kstream.TableJoined<K,KO>
  • org.apache.kafka.streams.processor.TaskId (implements java.lang.Comparable<T>)
  • org.apache.kafka.streams.processor.TaskMetadata
  • org.apache.kafka.streams.TestInputTopic<K,V>
  • org.apache.kafka.streams.TestOutputTopic<K,V>
  • org.apache.kafka.streams.test.TestRecord<K,V>
  • org.apache.kafka.streams.processor.ThreadMetadata
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.kafka.server.log.remote.storage.RemoteStorageException
        • org.apache.kafka.server.log.remote.storage.RemoteResourceNotFoundException
      • 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.SaslAuthenticationException
              • org.apache.kafka.common.errors.SslAuthenticationException
              • org.apache.kafka.common.errors.UnsupportedSaslMechanismException
            • org.apache.kafka.common.errors.AuthorizationException
              • org.apache.kafka.common.errors.ClusterAuthorizationException
              • org.apache.kafka.common.errors.DelegationTokenAuthorizationException
              • org.apache.kafka.common.errors.GroupAuthorizationException
              • org.apache.kafka.common.errors.TopicAuthorizationException
              • org.apache.kafka.common.errors.TransactionalIdAuthorizationException
            • org.apache.kafka.common.errors.BrokerIdNotRegisteredException
            • org.apache.kafka.common.errors.BrokerNotAvailableException
            • org.apache.kafka.common.errors.ControllerMovedException
            • org.apache.kafka.common.errors.DelegationTokenDisabledException
            • org.apache.kafka.common.errors.DelegationTokenExpiredException
            • org.apache.kafka.common.errors.DelegationTokenNotFoundException
            • org.apache.kafka.common.errors.DelegationTokenOwnerMismatchException
            • org.apache.kafka.common.errors.DuplicateBrokerRegistrationException
            • org.apache.kafka.common.errors.DuplicateResourceException
            • org.apache.kafka.common.errors.DuplicateSequenceException
            • org.apache.kafka.common.errors.FeatureUpdateFailedException
            • org.apache.kafka.common.errors.FencedInstanceIdException
            • org.apache.kafka.common.errors.FencedMemberEpochException
            • org.apache.kafka.common.errors.GroupIdNotFoundException
            • org.apache.kafka.common.errors.GroupMaxSizeReachedException
            • org.apache.kafka.common.errors.GroupNotEmptyException
            • org.apache.kafka.common.errors.GroupSubscribedToTopicException
            • org.apache.kafka.common.errors.IllegalGenerationException
            • org.apache.kafka.common.errors.InconsistentClusterIdException
            • org.apache.kafka.common.errors.InconsistentGroupProtocolException
            • org.apache.kafka.common.errors.InconsistentVoterSetException
            • org.apache.kafka.common.errors.IneligibleReplicaException
            • 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.InvalidPidMappingException
            • org.apache.kafka.common.errors.InvalidPrincipalTypeException
            • org.apache.kafka.common.errors.InvalidProducerEpochException
            • org.apache.kafka.common.InvalidRecordException
            • 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.InvalidTxnStateException
            • org.apache.kafka.common.errors.InvalidTxnTimeoutException
            • org.apache.kafka.common.errors.InvalidUpdateVersionException
            • org.apache.kafka.common.errors.LogDirNotFoundException
            • org.apache.kafka.common.errors.MemberIdRequiredException
            • org.apache.kafka.common.errors.NewLeaderElectedException
            • org.apache.kafka.common.errors.NoReassignmentInProgressException
            • org.apache.kafka.common.errors.OffsetMetadataTooLarge
            • org.apache.kafka.common.errors.OffsetMovedToTieredStorageException
            • org.apache.kafka.common.errors.OperationNotAttemptedException
            • org.apache.kafka.common.errors.OutOfOrderSequenceException
              • org.apache.kafka.common.errors.UnknownProducerIdException
            • org.apache.kafka.common.errors.PolicyViolationException
            • org.apache.kafka.common.errors.PositionOutOfRangeException
            • org.apache.kafka.common.errors.PrincipalDeserializationException
            • org.apache.kafka.common.errors.ProducerFencedException
            • org.apache.kafka.common.errors.ReassignmentInProgressException
            • org.apache.kafka.common.errors.RebalanceInProgressException
            • org.apache.kafka.common.errors.RecordBatchTooLargeException
            • org.apache.kafka.common.errors.RecordTooLargeException
            • org.apache.kafka.common.errors.ResourceNotFoundException
            • org.apache.kafka.common.errors.RetriableException
              • org.apache.kafka.common.errors.AuthorizerNotReadyException
              • org.apache.kafka.common.errors.ConcurrentTransactionsException
              • org.apache.kafka.common.errors.CoordinatorLoadInProgressException
              • org.apache.kafka.common.errors.CoordinatorNotAvailableException
              • org.apache.kafka.common.errors.CorruptRecordException
              • org.apache.kafka.common.errors.DisconnectException
              • org.apache.kafka.common.errors.FetchSessionIdNotFoundException
              • org.apache.kafka.common.errors.FetchSessionTopicIdException
              • org.apache.kafka.common.errors.InvalidFetchSessionEpochException
              • org.apache.kafka.common.errors.InvalidMetadataException
                • org.apache.kafka.common.errors.ElectionNotNeededException
                • org.apache.kafka.common.errors.EligibleLeadersNotAvailableException
                • org.apache.kafka.common.errors.FencedLeaderEpochException
                • org.apache.kafka.common.errors.InconsistentTopicIdException
                • org.apache.kafka.common.errors.KafkaStorageException
                • org.apache.kafka.common.errors.LeaderNotAvailableException
                • org.apache.kafka.common.errors.ListenerNotFoundException
                • org.apache.kafka.common.errors.NetworkException
                • org.apache.kafka.common.errors.NotLeaderForPartitionException
                  • org.apache.kafka.common.errors.NotLeaderOrFollowerException
                • org.apache.kafka.common.errors.PreferredLeaderNotAvailableException
                • org.apache.kafka.common.errors.ReplicaNotAvailableException
                • org.apache.kafka.common.errors.UnknownTopicIdException
                • org.apache.kafka.common.errors.UnknownTopicOrPartitionException
              • org.apache.kafka.common.errors.NotControllerException
              • org.apache.kafka.common.errors.NotCoordinatorException
              • org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
              • org.apache.kafka.common.errors.NotEnoughReplicasException
              • org.apache.kafka.common.errors.OffsetNotAvailableException
              • org.apache.kafka.clients.consumer.RetriableCommitFailedException
              • org.apache.kafka.common.errors.ThrottlingQuotaExceededException
              • org.apache.kafka.common.errors.TimeoutException
                • org.apache.kafka.clients.producer.BufferExhaustedException
              • org.apache.kafka.common.errors.UnknownLeaderEpochException
              • org.apache.kafka.common.errors.UnstableOffsetCommitException
            • org.apache.kafka.common.errors.SecurityDisabledException
            • org.apache.kafka.common.errors.SnapshotNotFoundException
            • org.apache.kafka.common.errors.StaleBrokerEpochException
            • org.apache.kafka.common.errors.StaleMemberEpochException
            • org.apache.kafka.common.errors.TopicDeletionDisabledException
            • org.apache.kafka.common.errors.TopicExistsException
            • org.apache.kafka.common.errors.TransactionAbortedException
            • org.apache.kafka.common.errors.TransactionalIdNotFoundException
            • org.apache.kafka.common.errors.TransactionCoordinatorFencedException
            • org.apache.kafka.common.errors.UnacceptableCredentialException
            • org.apache.kafka.common.errors.UnknownMemberIdException
            • org.apache.kafka.common.errors.UnknownServerException
            • org.apache.kafka.common.errors.UnreleasedInstanceIdException
            • org.apache.kafka.common.errors.UnsupportedAssignorException
            • org.apache.kafka.common.errors.UnsupportedByAuthenticationException
            • org.apache.kafka.common.errors.UnsupportedCompressionTypeException
            • org.apache.kafka.common.errors.UnsupportedForMessageFormatException
            • org.apache.kafka.common.errors.UnsupportedVersionException
          • 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.clients.consumer.LogTruncationException
          • org.apache.kafka.common.metrics.QuotaViolationException
          • org.apache.kafka.common.errors.SerializationException
            • org.apache.kafka.common.errors.RecordDeserializationException
          • 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.common.errors.WakeupException
  • org.apache.kafka.connect.data.Time
  • org.apache.kafka.connect.data.Timestamp
  • 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.common.metrics.stats.TokenBucket (implements org.apache.kafka.common.metrics.MeasurableStat)
  • org.apache.kafka.common.security.token.delegation.TokenInformation
  • org.apache.kafka.common.TopicCollection
    • org.apache.kafka.common.TopicCollection.TopicIdCollection
    • org.apache.kafka.common.TopicCollection.TopicNameCollection
  • org.apache.kafka.common.config.TopicConfig
  • org.apache.kafka.clients.admin.TopicDescription
  • org.apache.kafka.common.TopicIdPartition
  • org.apache.kafka.clients.admin.TopicListing
  • 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.streams.Topology
  • org.apache.kafka.streams.TopologyConfig.TaskConfig
  • org.apache.kafka.streams.TopologyTestDriver (implements java.io.Closeable)
  • org.apache.kafka.clients.admin.TransactionDescription
  • org.apache.kafka.clients.admin.TransactionListing
  • org.apache.kafka.clients.producer.UniformStickyPartitioner (implements org.apache.kafka.clients.producer.Partitioner)
  • org.apache.kafka.clients.admin.UnregisterBrokerResult
  • org.apache.kafka.clients.admin.UpdateFeaturesResult
  • org.apache.kafka.streams.processor.UsePartitionTimeOnInvalidTimestamp
  • org.apache.kafka.clients.admin.UserScramCredentialAlteration
    • org.apache.kafka.clients.admin.UserScramCredentialDeletion
    • org.apache.kafka.clients.admin.UserScramCredentialUpsertion
  • org.apache.kafka.clients.admin.UserScramCredentialsDescription
  • org.apache.kafka.common.Uuid (implements java.lang.Comparable<T>)
  • org.apache.kafka.common.serialization.UUIDDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.UUIDSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • org.apache.kafka.common.metrics.stats.Value (implements org.apache.kafka.common.metrics.MeasurableStat)
  • org.apache.kafka.streams.state.ValueAndTimestamp<V>
  • org.apache.kafka.connect.data.Values
  • org.apache.kafka.connect.data.Values.Parser
  • org.apache.kafka.connect.data.Values.SchemaDetector
  • org.apache.kafka.streams.state.VersionedRecord<V>
  • org.apache.kafka.common.serialization.VoidDeserializer (implements org.apache.kafka.common.serialization.Deserializer<T>)
  • org.apache.kafka.common.serialization.VoidSerializer (implements org.apache.kafka.common.serialization.Serializer<T>)
  • 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,VA>
• org.apache.kafka.common.security.auth.AuthenticationContext
• org.apache.kafka.server.authorizer.AuthorizableRequestContext
• org.apache.kafka.server.authorizer.AuthorizerServerInfo
• java.lang.AutoCloseable
  • org.apache.kafka.clients.admin.Admin
  • org.apache.kafka.server.policy.AlterConfigPolicy (also extends org.apache.kafka.common.Configurable)
  • java.io.Closeable
    • org.apache.kafka.server.authorizer.Authorizer (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.common.config.provider.ConfigProvider (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.connect.rest.ConnectRestExtension (also extends org.apache.kafka.common.Configurable, org.apache.kafka.connect.components.Versioned)
    • org.apache.kafka.clients.consumer.Consumer<K,V>
    • org.apache.kafka.common.serialization.Deserializer<T>
    • org.apache.kafka.connect.storage.HeaderConverter (also extends org.apache.kafka.common.Configurable)
    • 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.common.MessageFormatter (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.clients.producer.Partitioner (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.clients.producer.Producer<K,V>
    • org.apache.kafka.tools.api.RecordReader (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.server.log.remote.storage.RemoteLogMetadataManager (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.server.log.remote.storage.RemoteStorageManager (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.common.serialization.Serde<T>
    • org.apache.kafka.common.serialization.Serializer<T>
    • org.apache.kafka.common.security.auth.SslEngineFactory (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.connect.transforms.Transformation<R> (also extends org.apache.kafka.common.Configurable)
    • org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends org.apache.kafka.streams.state.KeyValueIterator<K,V>)
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V> (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.server.policy.CreateTopicPolicy (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.common.metrics.MetricsReporter (also extends org.apache.kafka.common.Reconfigurable)
  • org.apache.kafka.connect.transforms.predicates.Predicate<R> (also extends org.apache.kafka.common.Configurable)
  • org.apache.kafka.clients.producer.ProducerInterceptor<K,V> (also extends org.apache.kafka.common.Configurable)
• org.apache.kafka.streams.kstream.BranchedKStream<K,V>
• org.apache.kafka.clients.producer.Callback
• javax.security.auth.callback.CallbackHandler
  • org.apache.kafka.common.security.auth.AuthenticateCallbackHandler
• org.apache.kafka.streams.processor.Cancellable
• org.apache.kafka.server.quota.ClientQuotaEntity
• org.apache.kafka.server.quota.ClientQuotaEntity.ConfigEntity
• org.apache.kafka.common.ClusterResourceListener
• org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>
• org.apache.kafka.streams.processor.CommitCallback
• org.apache.kafka.common.config.ConfigChangeCallback
• org.apache.kafka.common.config.ConfigDef.Recommender
• org.apache.kafka.common.config.ConfigDef.Validator
• org.apache.kafka.common.Configurable
  • org.apache.kafka.server.policy.AlterConfigPolicy (also extends java.lang.AutoCloseable)
  • org.apache.kafka.server.authorizer.Authorizer (also extends java.io.Closeable)
  • org.apache.kafka.server.quota.ClientQuotaCallback
  • org.apache.kafka.common.config.provider.ConfigProvider (also extends java.io.Closeable)
  • org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy (also extends java.lang.AutoCloseable)
  • org.apache.kafka.connect.rest.ConnectRestExtension (also extends java.io.Closeable, org.apache.kafka.connect.components.Versioned)
  • org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V> (also extends java.lang.AutoCloseable)
  • org.apache.kafka.server.policy.CreateTopicPolicy (also extends java.lang.AutoCloseable)
  • org.apache.kafka.streams.errors.DeserializationExceptionHandler
  • org.apache.kafka.connect.storage.HeaderConverter (also extends java.io.Closeable)
  • org.apache.kafka.common.MessageFormatter (also extends java.io.Closeable)
  • org.apache.kafka.clients.producer.Partitioner (also extends java.io.Closeable)
  • org.apache.kafka.connect.transforms.predicates.Predicate<R> (also extends java.lang.AutoCloseable)
  • org.apache.kafka.clients.producer.ProducerInterceptor<K,V> (also extends java.lang.AutoCloseable)
  • org.apache.kafka.streams.errors.ProductionExceptionHandler
  • org.apache.kafka.common.Reconfigurable
    • org.apache.kafka.common.metrics.MetricsReporter (also extends java.lang.AutoCloseable)
  • org.apache.kafka.tools.api.RecordReader (also extends java.io.Closeable)
  • org.apache.kafka.server.log.remote.storage.RemoteLogMetadataManager (also extends java.io.Closeable)
  • org.apache.kafka.server.log.remote.storage.RemoteStorageManager (also extends java.io.Closeable)
  • org.apache.kafka.common.security.auth.SecurityProviderCreator
  • org.apache.kafka.common.security.auth.SslEngineFactory (also extends java.io.Closeable)
  • org.apache.kafka.connect.transforms.Transformation<R> (also extends java.io.Closeable)
• org.apache.kafka.connect.health.ConnectClusterDetails
• org.apache.kafka.connect.health.ConnectClusterState
• 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.connect.connector.ConnectorContext
  • org.apache.kafka.connect.sink.SinkConnectorContext
  • org.apache.kafka.connect.source.SourceConnectorContext
• org.apache.kafka.connect.rest.ConnectRestExtensionContext
• org.apache.kafka.clients.consumer.ConsumerPartitionAssignor
• org.apache.kafka.clients.consumer.ConsumerRebalanceListener
• org.apache.kafka.connect.storage.Converter
• org.apache.kafka.streams.kstream.EmitStrategy
• org.apache.kafka.connect.sink.ErrantRecordReporter
• 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.common.header.Header
• org.apache.kafka.connect.header.Header
• org.apache.kafka.connect.header.Headers.HeaderTransform
• org.apache.kafka.common.metrics.stats.Histogram.BinScheme
• org.apache.kafka.streams.kstream.Initializer<VA>
• java.lang.Iterable<T>
  • org.apache.kafka.common.header.Headers
  • org.apache.kafka.connect.header.Headers
• 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.KafkaClientSupplier
• org.apache.kafka.common.KafkaFuture.BaseFunction<A,B>
• org.apache.kafka.common.KafkaFuture.BiConsumer<A,B>
• org.apache.kafka.common.security.auth.KafkaPrincipalBuilder
• org.apache.kafka.common.security.auth.KafkaPrincipalSerde
• org.apache.kafka.streams.KafkaStreams.StateListener
• 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.common.security.auth.Login
• org.apache.kafka.streams.kstream.Merger<K,V>
• org.apache.kafka.common.Metric
• org.apache.kafka.common.metrics.MetricsContext
• org.apache.kafka.common.metrics.MetricValueProvider<T>
  • org.apache.kafka.common.metrics.Gauge<T>
  • org.apache.kafka.common.metrics.Measurable
    • org.apache.kafka.common.metrics.MeasurableStat (also extends org.apache.kafka.common.metrics.Stat)
• org.apache.kafka.streams.kstream.NamedOperation<T>
  • org.apache.kafka.streams.kstream.Suppressed<K>
• org.apache.kafka.common.security.oauthbearer.OAuthBearerToken
• org.apache.kafka.clients.consumer.OffsetCommitCallback
• org.apache.kafka.connect.storage.OffsetStorageReader
• 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.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.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.connect.mirror.ReplicationPolicy
• org.apache.kafka.streams.state.RocksDBConfigSetter
• org.apache.kafka.connect.data.Schema
• org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,V>
• org.apache.kafka.streams.kstream.SessionWindowedKStream<K,V>
• org.apache.kafka.connect.sink.SinkTaskContext
• org.apache.kafka.connect.source.SourceTaskContext
• org.apache.kafka.common.metrics.Stat
  • org.apache.kafka.common.metrics.CompoundStat
  • org.apache.kafka.common.metrics.MeasurableStat (also extends org.apache.kafka.common.metrics.Measurable)
• 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.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.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.connect.connector.Task
• org.apache.kafka.streams.TaskMetadata
• 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.connect.source.TransactionContext
• 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>
• org.apache.kafka.connect.components.Versioned
  • org.apache.kafka.connect.rest.ConnectRestExtension (also extends java.io.Closeable, org.apache.kafka.common.Configurable)

Annotation Interface Hierarchy

• org.apache.kafka.common.annotation.InterfaceStability.Evolving (implements java.lang.annotation.Annotation)
• org.apache.kafka.common.annotation.InterfaceStability.Stable (implements java.lang.annotation.Annotation)
• org.apache.kafka.common.annotation.InterfaceStability.Unstable (implements java.lang.annotation.Annotation)

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • org.apache.kafka.common.acl.AclOperation
    • org.apache.kafka.common.acl.AclPermissionType
    • org.apache.kafka.clients.admin.AlterConfigOp.OpType
    • org.apache.kafka.server.authorizer.AuthorizationResult
    • org.apache.kafka.server.quota.ClientQuotaEntity.ConfigEntityType
    • org.apache.kafka.server.quota.ClientQuotaType
    • org.apache.kafka.common.config.ConfigDef.Importance
    • org.apache.kafka.common.config.ConfigDef.Type
    • org.apache.kafka.common.config.ConfigDef.Width
    • org.apache.kafka.clients.admin.ConfigEntry.ConfigSource
    • org.apache.kafka.clients.admin.ConfigEntry.ConfigType
    • org.apache.kafka.common.config.ConfigResource.Type
    • org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest.ClientType
    • org.apache.kafka.connect.source.ConnectorTransactionBoundaries
    • org.apache.kafka.connect.health.ConnectorType
    • org.apache.kafka.common.ConsumerGroupState
    • org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.RebalanceProtocol
    • org.apache.kafka.connect.storage.ConverterType
    • org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
    • org.apache.kafka.common.ElectionType
    • org.apache.kafka.streams.kstream.EmitStrategy.StrategyType
    • org.apache.kafka.connect.source.ExactlyOnceSupport
    • org.apache.kafka.streams.query.FailureReason
    • org.apache.kafka.clients.admin.FeatureUpdate.UpgradeType
    • org.apache.kafka.common.IsolationLevel
    • org.apache.kafka.streams.KafkaStreams.State
    • org.apache.kafka.streams.kstream.Materialized.StoreType
    • org.apache.kafka.clients.consumer.OffsetResetStrategy
    • org.apache.kafka.common.resource.PatternType
    • org.apache.kafka.common.metrics.stats.Percentiles.BucketSizing
    • org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
    • org.apache.kafka.streams.processor.PunctuationType
    • org.apache.kafka.server.log.remote.storage.RemoteLogSegmentState
    • org.apache.kafka.server.log.remote.storage.RemotePartitionDeleteState
    • org.apache.kafka.server.log.remote.storage.RemoteStorageManager.IndexType
    • org.apache.kafka.common.resource.ResourceType
    • org.apache.kafka.connect.data.Schema.Type
    • org.apache.kafka.clients.admin.ScramMechanism
    • org.apache.kafka.common.security.auth.SecurityProtocol
    • org.apache.kafka.common.metrics.Sensor.RecordingLevel
    • org.apache.kafka.connect.source.SourceTask.TransactionBoundary
    • org.apache.kafka.common.config.SslClientAuth
    • org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse
    • org.apache.kafka.streams.Topology.AutoOffsetReset
    • org.apache.kafka.clients.admin.TransactionState