JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Hierarchy For All Packages
Package Hierarchies:
kafka.assignor
,
kafka.common
,
kafka.durability.db.serdes
,
kafka.durability.events.serdes
,
kafka.durability.tools
,
kafka.internals.generated
,
kafka.metrics
,
kafka.tier
,
kafka.tier.client
,
kafka.tier.domain
,
kafka.tier.exceptions
,
kafka.tier.fetcher
,
kafka.tier.fetcher.offsetcache
,
kafka.tier.serdes
,
kafka.tier.state
,
kafka.tier.store
,
kafka.tier.store.encryption
,
kafka.tier.tools
,
kafka.tier.tools.common
,
kafka.tier.tools.restore
,
kafka.tier.topic
,
kafka.tools
,
kafka.utils.checksum
Class Hierarchy
java.lang.
Object
org.apache.kafka.common.config.AbstractConfig
kafka.tier.tools.
TierTopicMaterializationToolConfig
org.apache.kafka.common.utils.AbstractIterator<T> (implements java.util.
Iterator
<E>)
kafka.tier.state.
FileTierPartitionIterator
kafka.tier.tools.restore.
SegmentStateIterator
org.apache.kafka.common.record.AbstractRecords (implements org.apache.kafka.common.record.Records)
org.apache.kafka.common.record.MemoryRecords
kafka.tier.fetcher.
ReclaimableMemoryRecords
com.yammer.metrics.reporting.AbstractReporter
com.yammer.metrics.reporting.JmxReporter (implements com.yammer.metrics.core.MetricProcessor<T>, com.yammer.metrics.core.MetricsRegistryListener)
kafka.metrics.
FilteringJmxReporter
kafka.tier.domain.
AbstractTierMetadata
kafka.tier.domain.
AbstractTierSegmentMetadata
kafka.tier.domain.
TierSegmentDeleteComplete
kafka.tier.domain.
TierSegmentDeleteInitiate
kafka.tier.domain.
TierSegmentUploadComplete
kafka.tier.domain.
TierSegmentUploadInitiate
kafka.tier.domain.
TierPartitionDeleteComplete
kafka.tier.domain.
TierPartitionDeleteInitiate
kafka.tier.domain.
TierPartitionFence
kafka.tier.domain.
TierPartitionForceRestore
kafka.tier.domain.
TierPartitionUnfreezeLogStartOffset
kafka.tier.domain.
TierTopicInitLeader
kafka.utils.checksum.
Adler32WithInPlaceUpdate
(implements kafka.utils.checksum.
ChecksumWithInPlaceUpdate
)
kafka.common.
AliveBrokersSnapshot
kafka.tier.store.
AzureBlockBlobTierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.common.
BalancerStatusDescriptionInternal
kafka.common.
BrokerAdditionDescriptionInternal
kafka.common.
BrokerAddStatus
kafka.common.
BrokerRemovalDescriptionInternal
kafka.common.
BrokerRemovalRequest
kafka.tier.fetcher.offsetcache.
CachedFetchOffsetMetadata
kafka.tier.fetcher.
CancellationContext
(implements java.io.
Closeable
)
kafka.utils.checksum.
CheckedFileIO
(implements java.lang.
AutoCloseable
)
kafka.utils.checksum.
Adler32CheckedFileIO
kafka.utils.checksum.
NoChecksumFileIO
kafka.tier.state.
ChecksumMigration
kafka.tier.store.encryption.
CleartextDataKey
kafka.tier.tools.common.
ComparatorInfo
kafka.tier.tools.common.
ComparatorInfo.ComparatorOutput
kafka.tier.tools.common.
ComparatorInfo.ComparatorReplicaInfo
kafka.durability.tools.
DumpDurabilityDb
kafka.tier.tools.
DumpTierPartitionState
kafka.tier.store.encryption.
EncryptionKeyManager
kafka.common.
EvenClusterLoadStatusDescriptionInternal
kafka.tier.tools.common.
FenceEventInfo
kafka.tier.fetcher.offsetcache.
FetchKey
kafka.tier.fetcher.offsetcache.
FetchOffsetCache
kafka.tier.fetcher.offsetcache.
FetchOffsetMetadata
kafka.tier.state.
FileTierPartitionState
(implements java.lang.
AutoCloseable
, kafka.tier.state.
TierPartitionState
)
kafka.tier.state.
FileTierPartitionState.MaterializationListener.Initialization
(implements kafka.tier.state.
FileTierPartitionState.MaterializationListener
)
kafka.tier.state.
FileTierPartitionState.MaterializationListener.LeaderEpoch
(implements kafka.tier.state.
FileTierPartitionState.MaterializationListener
)
kafka.tier.state.
FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
(implements kafka.tier.state.
FileTierPartitionState.MaterializationListener
)
kafka.tier.state.
FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
(implements kafka.tier.state.
FileTierPartitionState.MaterializationListener
)
kafka.tier.state.
FileTierPartitionStateUtils
kafka.tier.store.
GcsTierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.internals.generated.
GroupMetadataKey
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
GroupMetadataValue
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
GroupMetadataValue.MemberMetadata
(implements org.apache.kafka.common.protocol.Message)
kafka.tier.state.
Header
java.io.
InputStream
(implements java.io.
Closeable
)
kafka.tier.store.
AutoAbortingGenericInputStream
kafka.metrics.
KafkaYammerMetrics
(implements org.apache.kafka.common.Reconfigurable)
kafka.tier.store.encryption.
KeyContext
kafka.tier.store.encryption.
KeySha
kafka.tier.fetcher.
MemoryTracker
(implements java.lang.
AutoCloseable
)
kafka.tier.fetcher.
MemoryTracker.MemoryLease
kafka.tier.store.
MockInMemoryTierObjectStore
(implements java.lang.
AutoCloseable
, kafka.tier.store.
TierObjectStore
)
kafka.tier.serdes.
ObjectState
kafka.tier.state.
OffsetAndEpoch
kafka.internals.generated.
OffsetCommitKey
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
OffsetCommitValue
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.tier.fetcher.
PendingFetch
(implements java.lang.
Runnable
)
kafka.tier.fetcher.
PendingOffsetForTimestamp
(implements java.lang.
Runnable
)
kafka.tier.tools.
RecoveryUtils
kafka.common.
ReplicaExclusionCache
kafka.tier.tools.common.
RestoreInfo
kafka.tier.tools.common.
RestoreInfo.ComparatorReplicaInfo
kafka.tier.tools.common.
RestoreInfo.RestoreComparatorInput
kafka.tier.tools.common.
RestoreInfo.RestoreComparatorOutput
kafka.tier.tools.common.
RestoreInfo.RestoreRawInput
kafka.tier.tools.common.
RestoreInfo.RestoreRawOutput
kafka.tier.tools.common.
RestoreInfo.UnfreezeTriggerOutput
kafka.tier.tools.restore.
RestorePartitionOperator
kafka.tier.tools.restore.
RestoreTierPartitionState
kafka.tier.store.
S3TierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.tier.state.
SegmentState
kafka.tools.
StreamsResetter
com.google.flatbuffers.Struct
kafka.durability.events.serdes.
BaseInfo
kafka.durability.db.serdes.
EpochChain
kafka.tier.serdes.
OffsetAndEpoch
kafka.tier.serdes.
OpaqueDataField
kafka.tier.serdes.
UUID
com.google.flatbuffers.Table
kafka.tier.serdes.
CheckedFileIOHeader
kafka.durability.db.serdes.
Database
kafka.durability.events.serdes.
DeletePartition
kafka.durability.events.serdes.
DeleteRecords
kafka.durability.events.serdes.
EpochChange
kafka.durability.events.serdes.
EventKey
kafka.durability.db.serdes.
Header
kafka.durability.events.serdes.
HealthCheck
kafka.tier.serdes.
InitLeader
kafka.durability.events.serdes.
IsrExpand
kafka.tier.serdes.
MaterializationTrackingInfo
kafka.durability.events.serdes.
OffsetChange
kafka.tier.serdes.
PartitionDeleteComplete
kafka.tier.serdes.
PartitionDeleteInitiate
kafka.tier.serdes.
PartitionFence
kafka.tier.serdes.
PartitionForceRestore
kafka.durability.db.serdes.
PartitionInfo
kafka.tier.serdes.
PartitionUnfreezeLogStartOffset
kafka.durability.events.serdes.
RetentionChange
kafka.tier.serdes.
SegmentDeleteComplete
kafka.tier.serdes.
SegmentDeleteInitiate
kafka.tier.serdes.
SegmentUploadComplete
kafka.tier.serdes.
SegmentUploadInitiate
kafka.durability.events.serdes.
StartOffsetChange
kafka.tier.serdes.
TierKafkaKey
kafka.tier.serdes.
TierPartitionStateEntry
kafka.tier.serdes.
TierPartitionStateHeader
kafka.durability.db.serdes.
TopicInfo
kafka.common.
TenantHelpers
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.RetriableException
kafka.tier.exceptions.
TierMetadataRetriableException
kafka.tier.exceptions.
TierObjectStoreRetriableException
kafka.tier.store.encryption.
IncompatibleKeysetException
kafka.tier.exceptions.
TierMetadataDeserializationException
kafka.tier.exceptions.
TierMetadataFatalException
kafka.tier.exceptions.
TierObjectStoreFatalException
kafka.tier.exceptions.
TierPartitionStateIllegalListenerException
kafka.tier.exceptions.
TierTopicIncorrectPartitionCountException
kafka.tier.fetcher.
TierAbortedTxnReader
kafka.tier.fetcher.
TierFetcher
(implements kafka.server.BrokerReconfigurable)
kafka.tier.fetcher.
TierFetcherConfig
kafka.tier.fetcher.
TierFetchResult
kafka.tier.topic.
TierMessageFormatter
(implements org.apache.kafka.common.MessageFormatter)
kafka.tier.tools.
TierMetadataComparator
(implements java.lang.
AutoCloseable
)
kafka.tier.tools.
TierMetadataDebugger
kafka.tier.tools.
TierMetadataValidator
(implements java.lang.
AutoCloseable
)
kafka.tier.tools.
TierMetadataValidator.OffsetValidationResult
kafka.tier.domain.
TierObjectMetadata
kafka.tier.store.
TierObjectStore.ObjectMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.OpaqueData
kafka.tier.store.
TierObjectStore.TierStateRestoreSnapshotMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStoreConfig
kafka.tier.store.
AzureBlockBlobTierObjectStoreConfig
kafka.tier.store.
GcsTierObjectStoreConfig
kafka.tier.store.
S3TierObjectStoreConfig
kafka.tier.tools.
TierObjectStoreFactory
kafka.tier.store.
TierObjectStoreMetrics
kafka.tier.store.
TierObjectStoreMetricsEnabled
(implements kafka.tier.store.
TierObjectStore
)
kafka.tier.store.
TierObjectStoreUtils
kafka.tier.state.
TierPartitionStateFactory
kafka.tier.tools.
TierPartitionStateFencingTrigger
kafka.tier.tools.
TierPartitionStateRestoreTrigger
kafka.tier.tools.
TierPartitionUnfreezeLogStartOffsetTrigger
kafka.tier.tools.
TierRecoveryConfig
kafka.tier.
TierReplicaManager
kafka.tier.fetcher.
TierSegmentReader
kafka.tier.fetcher.
TierSegmentReader.NextOffsetAndBatchMetadata
kafka.tier.fetcher.
TierSegmentReader.RecordsAndNextBatchMetadata
kafka.tier.fetcher.
TierStateFetcher
kafka.tier.topic.
TierTopic
(implements kafka.tier.topic.
InitializedTierTopic
)
kafka.tier.client.
TierTopicClient
kafka.tier.topic.
TierTopicConsumer
(implements java.lang.
Runnable
)
kafka.tier.client.
TierTopicConsumerSupplier
(implements java.util.function.
Supplier
<T>)
kafka.tier.topic.
TierTopicManager
(implements java.lang.
Runnable
, kafka.tier.topic.
TierTopicAppender
)
kafka.tier.
TierTopicManagerCommitter
kafka.tier.topic.
TierTopicManagerConfig
kafka.tier.tools.
TierTopicMaterializationUtils
kafka.tier.topic.
TierTopicPartitioner
kafka.tier.client.
TierTopicProducerSupplier
(implements java.util.function.
Supplier
<T>)
kafka.tier.state.
TierUtils
kafka.tier.
TopicIdPartition
kafka.common.
TopicPlacement
kafka.common.
TopicPlacement.ConstraintCount
kafka.common.
TopicPlacement.Replica
kafka.common.
TopicPlacement.TopicPlacementValidator
(implements org.apache.kafka.common.config.ConfigDef.Validator)
kafka.assignor.
TopicReplicaAssignor.NewPartitions
kafka.internals.generated.
TransactionLogKey
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
TransactionLogValue
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
TransactionLogValue.PartitionsSchema
(implements org.apache.kafka.common.protocol.Message)
Interface Hierarchy
java.lang.
AutoCloseable
kafka.tier.store.
TierObjectStoreResponse
java.util.zip.
Checksum
kafka.utils.checksum.
ChecksumWithInPlaceUpdate
org.apache.kafka.common.Configurable
kafka.assignor.
TopicReplicaAssignorBuilder
kafka.tier.store.encryption.
EncryptionKeyManager.WellKnownKeypathHook
kafka.tier.state.
FileTierPartitionState.MaterializationListener
kafka.tier.topic.
InitializedTierTopic
kafka.tier.store.
TierObjectStore
kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
kafka.tier.state.
TierPartitionState
kafka.tier.
TierReplicaManager.ChangeListener
kafka.tier.topic.
TierTopicAppender
kafka.tier.topic.
TierTopicConsumer.ClientCtx
kafka.assignor.
TopicReplicaAssignor
Enum Hierarchy
java.lang.
Object
java.lang.
Enum
<E> (implements java.lang.
Comparable
<T>, java.io.
Serializable
)
kafka.common.
BrokerShutdownStatusV1
kafka.common.
TopicPlacement.ObserverPromotionPolicy
kafka.common.
PartitionReassignmentsStatusV1
kafka.tier.domain.
TierRecordType
kafka.tier.domain.
TierObjectMetadata.State
kafka.tier.store.
TierObjectStore.FileType
kafka.tier.store.
TierObjectStore.DataTypePathPrefix
kafka.tier.store.
TierObjectStore.Backend
kafka.tier.state.
TierPartitionState.AppendResult
kafka.tier.state.
TierPartitionState.RestoreResult
kafka.tier.state.
TierPartitionState.RecoveryOperation
kafka.tier.state.
TierPartitionStatus
kafka.utils.checksum.
Algorithm
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes