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.backupRestore.objectLifecycle.serdes
,
kafka.common
,
kafka.controller
,
kafka.durability.db.serdes
,
kafka.durability.events.serdes
,
kafka.durability.restore.db.serdes
,
kafka.durability.tools
,
kafka.internals.generated
,
kafka.restore
,
kafka.restore.configmap
,
kafka.restore.db
,
kafka.restore.messages
,
kafka.restore.operators
,
kafka.restore.rest
,
kafka.restore.schedulers
,
kafka.restore.statemachine
,
kafka.restore.statemachine.api
,
kafka.restore.statemachine.events
,
kafka.restore.statemachine.transitions
,
kafka.server.builders
,
kafka.tier
,
kafka.tier.backupobjectlifecycle
,
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.topic
,
kafka.tools
,
kafka.utils
,
kafka.utils.checksum
Class Hierarchy
java.lang.
Object
kafka.restore.schedulers.
AbstractAsyncServiceScheduler
kafka.restore.schedulers.
AsyncTaskScheduler
kafka.restore.schedulers.
DryrunAsyncTaskScheduler
kafka.restore.schedulers.
KafkaManager
kafka.restore.schedulers.
ObjectStoreManager
(implements kafka.restore.schedulers.
AsyncServiceSchedulerResultsReceiver
)
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.restore.operators.
SegmentStateIterator
org.eclipse.jetty.util.component.AbstractLifeCycle (implements org.eclipse.jetty.util.component.LifeCycle)
org.eclipse.jetty.util.component.ContainerLifeCycle (implements org.eclipse.jetty.util.component.Container, org.eclipse.jetty.util.component.Destroyable, org.eclipse.jetty.util.component.Dumpable.DumpableContainer)
org.eclipse.jetty.server.handler.AbstractHandler (implements org.eclipse.jetty.server.Handler)
kafka.restore.rest.
RestoreHandler
org.apache.kafka.common.record.AbstractRecords (implements org.apache.kafka.common.record.Records)
org.apache.kafka.common.record.MemoryRecords
kafka.tier.fetcher.
ReclaimableMemoryRecords
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.
TierCompactionCommitAndSwap
kafka.tier.domain.
TierPartitionDeleteComplete
kafka.tier.domain.
TierPartitionDeleteInitiate
kafka.tier.domain.
TierPartitionDeletePreInitiate
kafka.tier.domain.
TierPartitionFence
kafka.tier.domain.
TierPartitionForceRestore
kafka.tier.domain.
TierPartitionUnfreezeLogStartOffset
kafka.tier.domain.
TierTopicInitLeader
kafka.restore.statemachine.transitions.
AbstractTransition
(implements kafka.restore.statemachine.api.
Transition
<E>)
kafka.restore.statemachine.transitions.
FenceEventSentToPartitionFencedTransition
kafka.restore.statemachine.transitions.
ForceRestoreEventSentToPartitionRestoredTransition
kafka.restore.statemachine.transitions.
FtpsFetchedToFtpsRepairedTransition
kafka.restore.statemachine.transitions.
FtpsFetchedToPartitionRestoredTransition
kafka.restore.statemachine.transitions.
FtpsReconciledToFtpsUploadedTransition
kafka.restore.statemachine.transitions.
FtpsRepairedToFtpsReconciledTransition
kafka.restore.statemachine.transitions.
FtpsRepairedToSegmentsRepairedTransition
kafka.restore.statemachine.transitions.
FtpsUploadedToForceRestoreEventSentTransition
kafka.restore.statemachine.transitions.
PartitionFencedToFtpsFetchedTransition
kafka.restore.statemachine.transitions.
PartitionRestoredToRestoreStartOffsetEventSentTransition
kafka.restore.statemachine.transitions.
RestoreStartOffsetEventSentToStartOffsetRestoredTransition
kafka.restore.statemachine.transitions.
SegmentsRepairedToFtpsReconciledTransition
kafka.restore.statemachine.transitions.
StartToFenceEventSentTransition
kafka.utils.checksum.
Adler32WithInPlaceUpdate
(implements kafka.utils.checksum.
ChecksumWithInPlaceUpdate
)
kafka.common.
AliveBrokersSnapshot
(implements kafka.common.
AliveBrokersMetadata
)
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.common.
ClusterMetadataTopicsSnapshot
(implements kafka.common.
TopicsMetadataSnapshot
)
kafka.common.
ClusterMetadataTopicsSnapshot.ClusterMetadataPartitionSnapshot
(implements kafka.common.
TopicsMetadataSnapshot.PartitionSnapshot
)
kafka.common.
ClusterMetadataTopicsSnapshot.ClusterMetadataReplicaInfo
(implements kafka.common.
TopicsMetadataSnapshot.ReplicaInfo
)
kafka.tier.state.
CompactStats
kafka.tier.tools.common.
ComparatorInfo
kafka.tier.tools.common.
ComparatorInfo.ComparatorOutput
kafka.tier.tools.common.
ComparatorInfo.ComparatorReplicaInfo
kafka.restore.schedulers.
CompletableFutureRetryer
kafka.internals.generated.
ComputedQuotaKey
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
ComputedQuotaKey.EntityData
(implements org.apache.kafka.common.protocol.Message)
kafka.internals.generated.
ComputedQuotaValue
(implements org.apache.kafka.common.protocol.ApiMessage)
kafka.internals.generated.
ComputedQuotaValue.ComputedBrokerQuota
(implements org.apache.kafka.common.protocol.Message)
kafka.internals.generated.
ComputedQuotaValue.ComputedQuota
(implements org.apache.kafka.common.protocol.Message)
kafka.restore.configmap.
ConfigmapUtil
kafka.restore.statemachine.
Constants
kafka.restore.schedulers.
Constants
kafka.restore.schedulers.
CopyObjectOperator
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.restore.db.
FileRestoreDB
(implements kafka.restore.db.
RestoreDB
)
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.restore.operators.
FtpsSegmentView
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.tier.tools.
InspectTieredObjects
kafka.utils.
Interner
<T>
kafka.restore.db.
Job
kafka.server.builders.
KafkaApisBuilder
kafka.restore.schedulers.
KafkaConnectionPoolImpl
(implements kafka.restore.schedulers.
KafkaConnectionPool
)
kafka.restore.schedulers.
DryrunKafkaConnectionPoolImpl
kafka.restore.statemachine.events.
KafkaRestoreEvent
(implements kafka.restore.statemachine.api.
Event
)
kafka.tier.store.encryption.
KeyContext
kafka.tier.store.encryption.
KeySha
kafka.tier.backupobjectlifecycle.
LifecycleManager.BlobMetadata
kafka.tier.backupobjectlifecycle.
LifecycleManager.DeletionCounters
kafka.tier.backupobjectlifecycle.
LifecycleManager.ReductionInRetention
kafka.tier.backupobjectlifecycle.
LifecycleManagerConfig
kafka.tier.backupobjectlifecycle.
LifecycleManagerMetrics
kafka.restore.schedulers.
ListVersionsOperator
kafka.server.builders.
LogManagerBuilder
kafka.tier.fetcher.
MemoryTracker
(implements java.lang.
AutoCloseable
)
kafka.tier.fetcher.
MemoryTracker.MemoryLease
kafka.restore.messages.
Message
kafka.restore.messages.
MessageRequest
kafka.restore.messages.
AsyncTaskRequest
kafka.restore.messages.
ReconcileFtpsRequest
kafka.restore.messages.
RestoreFtpsRequest
kafka.restore.messages.
KafkaRequest
kafka.restore.messages.
KafkaFenceRequest
kafka.restore.messages.
KafkaFetchFtpsRequest
kafka.restore.messages.
KafkaForceRestoreRequest
kafka.restore.messages.
KafkaTierPartitionStatusRequest
kafka.restore.messages.
KafkaUnfreezeRequest
kafka.restore.messages.
KafkaValidateLogRangeRequest
kafka.restore.messages.
ObjectStoreRequest
kafka.restore.messages.
CopyObjectInStoreRequest
kafka.restore.messages.
ListObjectsInStoreRequest
kafka.restore.messages.
RestoreObjectsInStoreRequest
kafka.restore.messages.
UploadFtpsToStoreRequest
kafka.restore.messages.
MessageResponse
kafka.restore.messages.
AsyncTaskResponse
kafka.restore.messages.
ReconcileFtpsResponse
kafka.restore.messages.
RestoreFtpsResponse
kafka.restore.messages.
CopyObjectInStoreResponse
kafka.restore.messages.
KafkaResponse
kafka.restore.messages.
KafkaFenceResponse
kafka.restore.messages.
KafkaFetchFtpsResponse
kafka.restore.messages.
KafkaForceRestoreResponse
kafka.restore.messages.
KafkaTierPartitionStatusResponse
kafka.restore.messages.
KafkaUnfreezeResponse
kafka.restore.messages.
KafkaValidateLogRangeResponse
kafka.restore.messages.
ListObjectsInStoreResponse
kafka.restore.messages.
ObjectStoreResponse
kafka.restore.messages.
RestoreObjectsInStoreResponse
kafka.restore.messages.
UploadFtpsToStoreResponse
kafka.tier.store.
MockInMemoryTierObjectStore
(implements java.lang.
AutoCloseable
, kafka.tier.store.
TierObjectStore
)
kafka.tier.store.
MockInMemoryTierObjectStore.UploadedObject
kafka.tier.backupobjectlifecycle.
NameAndId
kafka.restore.configmap.
NodeConfig
kafka.tier.serdes.
ObjectState
kafka.restore.schedulers.
ObjectStorePoolImpl
(implements kafka.restore.schedulers.
ObjectStorePool
)
kafka.restore.schedulers.
DryrunObjectStorePoolImpl
kafka.tier.backupobjectlifecycle.
ObjectStoreUtils
kafka.tier.backupobjectlifecycle.
ObjectStoreUtils.DeletionRecord
kafka.tier.backupobjectlifecycle.
ObjectStoreUtilsContext
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.
OffsetIndexFetchRequest
kafka.restore.operators.
OperatorUtil
kafka.restore.configmap.
PartitionConfig
kafka.restore.schedulers.
PartitionLogRangeValidator
kafka.restore.db.
PartitionRestoreContext
kafka.restore.schedulers.
PartitionStatusFetcher
kafka.tier.fetcher.
PendingFetch
(implements java.lang.
Runnable
)
kafka.tier.fetcher.
PendingOffsetForTimestamp
(implements java.lang.
Runnable
)
kafka.utils.
ProcessUtils
kafka.restore.operators.
ReconcilePartitionOperator
kafka.tier.tools.
RecoveryUtils
kafka.common.
ReplicaExclusionCache
kafka.server.builders.
ReplicaManagerBuilder
kafka.restore.
Restore
kafka.restore.
RestoreConfig
kafka.restore.rest.
RestoreDBStatusResponse
kafka.restore.statemachine.
RestoreFiniteStateMachine
(implements kafka.restore.statemachine.api.
FiniteStateMachine
)
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.restore.
RestoreMetricsManager
kafka.restore.
RestoreMetricsUtil
kafka.restore.schedulers.
RestoreObjectMultipleResponseHandler
(implements kafka.restore.messages.
MultipleResponseHandler
)
kafka.restore.
RestoreOrchestrator
(implements kafka.restore.schedulers.
AsyncServiceSchedulerResultsReceiver
, kafka.restore.
MessageEmitter
)
kafka.restore.operators.
RestorePartitionOperator
kafka.restore.
RestorePartitionOperatorFactory
kafka.restore.rest.
RestoreRestServer
kafka.restore.
RestoreTierPartitionState
kafka.restore.configmap.
RestoreTopicListConfig
kafka.tier.backupobjectlifecycle.
RetryFramework
<U,V>
kafka.restore.schedulers.
S3ObjectStorePool
(implements kafka.restore.schedulers.
ObjectStorePool
)
kafka.tier.store.
S3TierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.restore.schedulers.
SchedulerUtil
kafka.tier.state.
SegmentState
kafka.restore.operators.
SegmentStateAndPath
kafka.restore.statemachine.api.
State
kafka.restore.statemachine.
StateMachineController
kafka.tier.backupobjectlifecycle.
StateManager
kafka.tier.backupobjectlifecycle.
StateManagerConfig
kafka.restore.rest.
StatusResponse
kafka.tools.
StreamsResetter
com.google.flatbuffers.Struct
kafka.durability.events.serdes.
BaseInfo
kafka.tier.serdes.
CompactStats
kafka.durability.db.serdes.
EpochChain
kafka.tier.serdes.
OffsetAndEpoch
kafka.tier.serdes.
OpaqueDataField
kafka.tier.serdes.
UUID
com.google.flatbuffers.Table
kafka.backupRestore.objectLifecycle.serdes.
BackupObjectsMetadata
kafka.backupRestore.objectLifecycle.serdes.
BlobMetadata
kafka.tier.serdes.
CheckedFileIOHeader
kafka.tier.serdes.
CompactionCommitAndSwap
kafka.durability.db.serdes.
Database
kafka.durability.restore.db.serdes.
Database
kafka.backupRestore.objectLifecycle.serdes.
DatedList
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.restore.db.serdes.
Header
kafka.backupRestore.objectLifecycle.serdes.
Header
kafka.durability.events.serdes.
HealthCheck
kafka.tier.serdes.
InitLeader
kafka.durability.events.serdes.
IsrExpand
kafka.durability.restore.db.serdes.
Job
kafka.backupRestore.objectLifecycle.serdes.
LifecycleManagerState
kafka.tier.serdes.
MaterializationTrackingInfo
kafka.durability.events.serdes.
OffsetChange
kafka.tier.serdes.
PartitionDeleteComplete
kafka.tier.serdes.
PartitionDeleteInitiate
kafka.tier.serdes.
PartitionDeletePreInitiate
kafka.tier.serdes.
PartitionFence
kafka.tier.serdes.
PartitionForceRestore
kafka.durability.db.serdes.
PartitionInfo
kafka.durability.restore.db.serdes.
PartitionRestoreContext
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.backupRestore.objectLifecycle.serdes.
TopicMetadata
kafka.backupRestore.objectLifecycle.serdes.
TopicRetentionData
kafka.common.
TenantHelpers
java.lang.
Thread
(implements java.lang.
Runnable
)
kafka.utils.ShutdownableThread (implements kafka.utils.Logging)
kafka.tier.backupobjectlifecycle.
LifecycleManager
kafka.restore.schedulers.
ThreadPoolMonitor
(implements java.lang.
Runnable
)
java.lang.
Throwable
(implements java.io.
Serializable
)
java.lang.
Exception
kafka.restore.statemachine.api.
FiniteStateMachineException
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.restore.schedulers.
PermanentException
kafka.restore.schedulers.
RetryableException
kafka.tier.exceptions.
TierMetadataDeserializationException
kafka.tier.exceptions.
TierMetadataFatalException
kafka.tier.exceptions.
TierObjectStoreFatalException
kafka.tier.exceptions.
TierPartitionStateIllegalListenerException
kafka.tier.backupobjectlifecycle.
StateManager.LifecycleManagerVersionException
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.BackupObjectsListMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.KeyAndVersion
kafka.tier.store.
TierObjectStore.LifecycleManagerStateMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
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.
MockInMemoryTierObjectStoreConfig
kafka.tier.store.
S3TierObjectStoreConfig
kafka.tier.tools.
TierObjectStoreFactory
kafka.tier.store.
TierObjectStoreLinearRetry
(implements kafka.tier.store.
TierObjectStoreRetryPolicy
)
kafka.tier.store.
TierObjectStoreMetrics
kafka.tier.store.
TierObjectStoreMetricsEnabled
(implements kafka.tier.store.
TierObjectStore
)
kafka.tier.store.
TierObjectStoreRetryPolicy.RetryInfo
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.backupobjectlifecycle.
TierTopicReader
kafka.tier.backupobjectlifecycle.
TierTopicReaderConfig
kafka.tier.state.
TierUtils
kafka.restore.configmap.
TopicConfig
kafka.tier.
TopicIdPartition
kafka.restore.configmap.
TopicPartitionConfigMapGenerator
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)
kafka.restore.db.
Utils
kafka.tier.store.
VersionInformation
kafka.tier.store.
S3VersionInformation
Interface Hierarchy
kafka.common.
AliveBrokersMetadata
kafka.restore.schedulers.
AsyncServiceSchedulerResultsReceiver
java.lang.
AutoCloseable
kafka.tier.store.
TierObjectStoreResponse
java.util.zip.
Checksum
kafka.utils.checksum.
ChecksumWithInPlaceUpdate
kafka.controller.
ClusterBalanceManager.BalanceManagerOperationInvocationClientCallback
kafka.controller.
ClusterBalanceManager.BalanceManagerStatusQueryClientCallback
<R>
kafka.common.
ClusterMetadataTopicsSnapshot.PartitionInfoSupplier
org.apache.kafka.common.Configurable
kafka.assignor.
TopicReplicaAssignorBuilder
kafka.tier.store.encryption.
EncryptionKeyManager.WellKnownKeypathHook
kafka.restore.statemachine.api.
Event
kafka.tier.state.
FileTierPartitionState.MaterializationListener
kafka.restore.statemachine.api.
FiniteStateMachine
kafka.tier.topic.
InitializedTierTopic
kafka.restore.schedulers.
KafkaConnectionPool
kafka.restore.
MessageEmitter
org.apache.kafka.image.MetadataImageListener
kafka.controller.
ClusterBalanceManager
kafka.restore.messages.
MultipleResponseHandler
kafka.restore.schedulers.
ObjectStorePool
kafka.restore.db.
RestoreDB
kafka.tier.store.
TierObjectStore
kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
kafka.tier.store.
TierObjectStoreRetryPolicy
kafka.tier.state.
TierPartitionState
kafka.tier.
TierReplicaManager.ChangeListener
kafka.tier.topic.
TierTopicAppender
kafka.tier.topic.
TierTopicConsumer.ClientCtx
kafka.assignor.
TopicReplicaAssignor
kafka.common.
TopicsMetadataSnapshot
kafka.common.
TopicsMetadataSnapshot.PartitionSnapshot
kafka.common.
TopicsMetadataSnapshot.ReplicaInfo
kafka.restore.statemachine.api.
Transition
<E>
Enum Hierarchy
java.lang.
Object
java.lang.
Enum
<E> (implements java.lang.
Comparable
<T>, java.io.
Serializable
)
kafka.common.
ControlledShutdownRequestReason
kafka.common.
BrokerShutdownStatusV1
kafka.common.
TopicPlacement.ObserverPromotionPolicy
kafka.common.
PartitionReassignmentsStatusV1
kafka.restore.messages.
MessageResult
kafka.restore.messages.
MessageStatusCode
kafka.restore.db.
PartitionRestoreContext.RestoreStatus
kafka.restore.db.
PartitionRestoreContext.RestoreState
kafka.restore.db.
Job.JobStatus
kafka.restore.
OrchestratorStatus
kafka.restore.schedulers.
AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus
kafka.tier.domain.
TierRecordType
kafka.tier.domain.
TierUploadType
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