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.catalog
,
kafka.catalog.event
,
kafka.catalog.exceptions
,
kafka.catalog.metadata
,
kafka.common
,
kafka.controller
,
kafka.durability.db.kraft.serdes
,
kafka.durability.db.serdes
,
kafka.durability.events.broker.serdes
,
kafka.durability.events.controller.serdes
,
kafka.durability.events.serdes
,
kafka.durability.exception
,
kafka.durability.ondemand
,
kafka.durability.restore.db.serdes
,
kafka.durability.serdes
,
kafka.durability.tools
,
kafka.internals.generated
,
kafka.log.remote
,
kafka.restore
,
kafka.restore.configmap
,
kafka.restore.db
,
kafka.restore.messages
,
kafka.restore.operators
,
kafka.restore.rest
,
kafka.restore.rpo
,
kafka.restore.schedulers
,
kafka.restore.snapshot
,
kafka.restore.statemachine
,
kafka.restore.statemachine.api
,
kafka.restore.statemachine.events
,
kafka.restore.statemachine.transitions
,
kafka.server
,
kafka.server.builders
,
kafka.server.cell
,
kafka.tier
,
kafka.tier.backupObjectLifecycle
,
kafka.tier.client
,
kafka.tier.domain
,
kafka.tier.exceptions
,
kafka.tier.fetcher
,
kafka.tier.fetcher.offsetcache
,
kafka.tier.raft
,
kafka.tier.serdes
,
kafka.tier.snapshot
,
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
,
kafka.utils.cloud
Class Hierarchy
java.lang.
Object
kafka.restore.schedulers.
AbstractAsyncServiceScheduler
kafka.restore.schedulers.
AsyncTaskScheduler
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
kafka.restore.snapshot.
TierRecordsIterator
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.
TierMetadataSnapshotUploadComplete
kafka.tier.domain.
TierMetadataSnapshotUploadInitiate
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.
PartitionFencedToFtpsRepairedTransition
kafka.restore.statemachine.transitions.
PartitionFencedToPartitionRestoredTransition
kafka.restore.statemachine.transitions.
PartitionRestoredToRestoreStartOffsetEventSentTransition
kafka.restore.statemachine.transitions.
PreConditionReadyToFenceEventSentTransition
kafka.restore.statemachine.transitions.
RestoreStartOffsetEventSentToStartOffsetRestoredTransition
kafka.restore.statemachine.transitions.
SegmentsRepairedToFtpsReconciledTransition
kafka.restore.statemachine.transitions.
StartToPreConditionReadyTransition
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
com.google.flatbuffers.BaseVector
kafka.durability.db.serdes.
AuditRunInfo.Vector
kafka.backupRestore.objectLifecycle.serdes.
BackupObjectsMetadata.Vector
kafka.durability.events.serdes.
BaseInfo.Vector
kafka.backupRestore.objectLifecycle.serdes.
BlobMetadata.Vector
kafka.tier.serdes.
CheckedFileIOHeader.Vector
kafka.tier.serdes.
CompactionCommitAndSwap.Vector
kafka.tier.serdes.
CompactStats.Vector
kafka.durability.db.serdes.
Database.Vector
kafka.durability.restore.db.serdes.
Database.Vector
kafka.backupRestore.objectLifecycle.serdes.
DatedList.Vector
kafka.durability.events.broker.serdes.
DeletePartition.Vector
kafka.durability.events.broker.serdes.
DeleteRecords.Vector
kafka.durability.serdes.
EpochChain.Vector
kafka.durability.db.kraft.serdes.
EpochChainWithLeader.Vector
kafka.durability.events.broker.serdes.
EpochChange.Vector
kafka.durability.events.serdes.
EventKey.Vector
kafka.durability.db.serdes.
Header.Vector
kafka.durability.restore.db.serdes.
Header.Vector
kafka.backupRestore.objectLifecycle.serdes.
Header.Vector
kafka.durability.events.serdes.
HealthCheck.Vector
kafka.tier.serdes.
InitLeader.Vector
kafka.durability.events.broker.serdes.
InjectState.Vector
kafka.durability.events.broker.serdes.
IsrExpand.Vector
kafka.durability.restore.db.serdes.
Job.Vector
kafka.durability.db.kraft.serdes.
KRaftEpochInfo.Vector
kafka.durability.events.controller.serdes.
KRaftHWMChange.Vector
kafka.durability.events.controller.serdes.
KRaftLeaderChange.Vector
kafka.durability.events.controller.serdes.
KRaftLogSnapshotGeneration.Vector
kafka.durability.events.controller.serdes.
KRaftLogStartOffsetChange.Vector
kafka.durability.events.controller.serdes.
KRaftNodeStartUp.Vector
kafka.durability.db.kraft.serdes.
KRaftPartitionInfo.Vector
kafka.durability.db.kraft.serdes.
KRaftQuorumInfo.Vector
kafka.backupRestore.objectLifecycle.serdes.
LifecycleManagerState.Vector
kafka.tier.serdes.
MaterializationTrackingInfo.Vector
kafka.tier.serdes.
MetadataSnapshotUploadComplete.Vector
kafka.tier.serdes.
MetadataSnapshotUploadInitiate.Vector
kafka.tier.serdes.
OffsetAndEpoch.Vector
kafka.durability.events.broker.serdes.
OffsetChange.Vector
kafka.tier.serdes.
OffsetRange.Vector
kafka.tier.serdes.
OpaqueDataField.Vector
kafka.tier.serdes.
PartitionDeleteComplete.Vector
kafka.tier.serdes.
PartitionDeleteInitiate.Vector
kafka.tier.serdes.
PartitionDeletePreInitiate.Vector
kafka.tier.serdes.
PartitionFence.Vector
kafka.tier.serdes.
PartitionForceRestore.Vector
kafka.durability.db.serdes.
PartitionInfo.Vector
kafka.durability.restore.db.serdes.
PartitionRestoreContext.Vector
kafka.tier.serdes.
PartitionUnfreezeLogStartOffset.Vector
kafka.durability.events.controller.serdes.
QuorumVoterFetchOffsetRecord.Vector
kafka.durability.events.broker.serdes.
RetentionChange.Vector
kafka.tier.serdes.
SegmentDeleteComplete.Vector
kafka.tier.serdes.
SegmentDeleteInitiate.Vector
kafka.tier.serdes.
SegmentUploadComplete.Vector
kafka.tier.serdes.
SegmentUploadInitiate.Vector
kafka.tier.serdes.
SnapshotTrackingInfo.Vector
kafka.durability.events.broker.serdes.
StartOffsetChange.Vector
kafka.tier.serdes.
TierKafkaKey.Vector
kafka.tier.serdes.
TierPartitionStateEntry.Vector
kafka.tier.serdes.
TierPartitionStateHeader.Vector
kafka.tier.serdes.
TierTopicSnapshot.Vector
kafka.tier.serdes.
TierTopicSnapshotEntry.Vector
kafka.tier.serdes.
TierTopicSnapshotHeader.Vector
kafka.durability.db.serdes.
TopicInfo.Vector
kafka.backupRestore.objectLifecycle.serdes.
TopicMetadata.Vector
kafka.backupRestore.objectLifecycle.serdes.
TopicRetentionData.Vector
kafka.tier.serdes.
UUID.Vector
kafka.common.
BrokerAdditionDescriptionInternal
kafka.common.
BrokerAddStatus
kafka.catalog.
BrokerConfigChangeListener
(implements kafka.server.BrokerReconfigurable)
kafka.common.
BrokerRemovalDescriptionInternal
kafka.common.
BrokerRemovalRequest
kafka.tier.fetcher.offsetcache.
CachedFetchOffsetMetadata
kafka.tier.fetcher.
CancellationContext
(implements java.io.
Closeable
)
kafka.catalog.
CatalogMetrics
kafka.catalog.
CatalogMetrics.LongGauge
(implements org.apache.kafka.common.metrics.Gauge<T>)
kafka.catalog.
CatalogTopicConfig
kafka.common.
CellLoadDescriptionInternal
kafka.server.cell.
CellLoadRefresher
kafka.utils.checksum.
CheckedFileIO
(implements java.lang.
AutoCloseable
)
kafka.utils.checksum.
Adler32CheckedFileIO
kafka.utils.checksum.
NoChecksumFileIO
kafka.tier.state.
ChecksumUtils
kafka.tier.store.encryption.
CleartextDataKey
kafka.catalog.metadata.
ClusterLinkInfo
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.assignor.
ConfluentReplicaPlacer
(implements org.apache.kafka.metadata.placement.ReplicaPlacer)
kafka.utils.
ConfluentUtils
kafka.restore.statemachine.
Constants
kafka.restore.schedulers.
Constants
kafka.durability.ondemand.
Constants
kafka.restore.schedulers.
CopyObjectOperator
kafka.tier.tools.
DownloadTieredObject
kafka.durability.tools.
DumpDurabilityDb
kafka.tier.tools.
DumpTierPartitionState
kafka.tier.store.encryption.
EncryptionKeyManager
kafka.utils.cloud.
EpochAndSeqNumber
(implements java.lang.
Comparable
<T>)
kafka.common.
EvenClusterLoadPlanBrokerStats
kafka.common.
EvenClusterLoadPlanDetailedClusterBalanceStats
kafka.common.
EvenClusterLoadPlanGoalOverview
kafka.common.
EvenClusterLoadPlanGoalStats
kafka.common.
EvenClusterLoadPlanInternal
kafka.common.
EvenClusterLoadPlanInternalBrokerRelatedStats
kafka.common.
EvenClusterLoadPlanInternalClusterRelatedStats
kafka.common.
EvenClusterLoadPlanInternalGoalRelatedStats
kafka.common.
EvenClusterLoadPlanInternalReplicaMovementStats
kafka.common.
EvenClusterLoadPlanRejectingGoal
kafka.common.
EvenClusterLoadPlanResources
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.
FileTierPartitionStateSnapshotObject
kafka.tier.state.
FileTierPartitionStateUtils
kafka.restore.schedulers.
FtpsFetcher
kafka.restore.operators.
FtpsSegmentView
kafka.restore.snapshot.
FtpsSnapshotMaterializer
kafka.restore.snapshot.
FtpsStateForRestore
kafka.tier.store.
GcsTierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.durability.ondemand.
GetAuditJobStatusDetail
kafka.durability.ondemand.
GetAuditJobStatusRequest
kafka.durability.ondemand.
GetAuditJobStatusResponseSummary
kafka.tier.state.
Header
kafka.catalog.
InMemoryLocalStore
(implements kafka.catalog.
LocalStore
)
java.io.
InputStream
(implements java.io.
Closeable
)
kafka.tier.store.
AutoAbortingGenericInputStream
kafka.tier.store.
AzureBlockBlobAutoAbortingInputStream
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.statemachine.events.
KafkaRestoreEvent
(implements kafka.restore.statemachine.api.
Event
)
kafka.tier.store.encryption.
KeyContext
kafka.tier.store.encryption.
KeySha
kafka.catalog.
KRaftMetadataCollector
(implements org.apache.kafka.image.publisher.MetadataPublisher)
kafka.tier.raft.
KRaftSnapshotManager
(implements io.confluent.kafka.raft.SimpleRaftTracer)
kafka.tier.raft.
KRaftSnapshotObject
(implements java.lang.
Comparable
<T>)
kafka.tier.raft.
KRaftSnapshotObjectUtils
kafka.tier.backupObjectLifecycle.
LifecycleManager.BlobMetadata
kafka.tier.backupObjectLifecycle.
LifecycleManager.DeletionCounters
kafka.tier.backupObjectLifecycle.
LifecycleManager.ReductionInRetention
kafka.tier.backupObjectLifecycle.
LifecycleManagerConfig
kafka.tier.backupObjectLifecycle.
LifecycleManagerMetrics
kafka.utils.cloud.
LinkedCloudObject
kafka.restore.schedulers.
ListVersionsOperator
kafka.tier.raft.
LocalSnapshotObject
(implements java.lang.
Comparable
<T>)
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.
RestoreFtpsFromSnapshotRequest
kafka.restore.messages.
RestoreFtpsRequest
kafka.restore.messages.
KafkaRequest
kafka.restore.messages.
KafkaFenceRequest
kafka.restore.messages.
KafkaFetchFtpsRequest
kafka.restore.messages.
KafkaForceRestoreRequest
kafka.restore.messages.
KafkaPreConditionCheckRequest
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.
KafkaPreConditionCheckResponse
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.catalog.event.
MetadataCollectorEvent
(implements org.apache.kafka.queue.EventQueue.Event)
kafka.catalog.event.
BrokerDefaultConfigChangeEvent
kafka.catalog.event.
CacheBuildEvent
kafka.catalog.event.
ClusterLinkConfigChangeEvent
kafka.catalog.event.
ClusterLinkCreationEvent
kafka.catalog.event.
ClusterLinkDeletionEvent
kafka.catalog.event.
CollectorStartupEvent
kafka.catalog.event.
CollectorStopEvent
kafka.catalog.event.
MirrorTopicChangeEvent
kafka.catalog.event.
SnapshotEvent
kafka.catalog.event.
TopicConfigChangeEvent
kafka.catalog.event.
TopicCreationEvent
kafka.catalog.event.
TopicDeletionEvent
kafka.catalog.event.
TopicPartitionChangeEvent
kafka.catalog.
MetadataCollectorEventQueue
(implements java.lang.
AutoCloseable
)
kafka.catalog.
MetadataEventUtils
kafka.catalog.metadata.
MirrorTopicInfo
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.tier.backupObjectLifecycle.
ObjectStoreUtils
kafka.tier.backupObjectLifecycle.
ObjectStoreUtils.DeletionRecord
kafka.tier.backupObjectLifecycle.
ObjectStoreUtilsContext
kafka.tier.state.
OffsetAndEpoch
kafka.tier.fetcher.
OffsetIndexFetchRequest
kafka.durability.ondemand.
OnDemandAudit
kafka.durability.ondemand.
OnDemandAuditJobOrchestrator
kafka.durability.ondemand.
OnDemandAuditJobUtil
kafka.restore.operators.
OperatorUtil
kafka.restore.configmap.
PartitionConfig
kafka.restore.schedulers.
PartitionLogRangeValidator
kafka.restore.db.
PartitionRestoreContext
kafka.restore.rpo.
PartitionRpo
kafka.restore.schedulers.
PartitionStatusFetcher
kafka.restore.rest.
PartitionStatusResponse
kafka.tier.fetcher.
PendingFetch
(implements java.lang.
Runnable
)
kafka.tier.fetcher.
PendingOffsetForTimestamp
(implements java.lang.
Runnable
)
kafka.restore.snapshot.
PointInTimeTierPartitionStateBuilder
kafka.restore.snapshot.
PointInTimeTierPartitionStateBuilder.FtpsSnapshotsMetadata
kafka.utils.
ProcessUtils
kafka.restore.operators.
ReconcilePartitionOperator
kafka.tier.tools.
RecoveryUtils
kafka.log.remote.
RemoteLogManager
(implements java.io.
Closeable
)
kafka.server.
ReplicaAlterLogDirsTierStateMachine
(implements kafka.server.
TierStateMachine
)
kafka.common.
ReplicaExclusionCache
kafka.server.builders.
ReplicaManagerBuilder
kafka.utils.
RequestQueueMap
<K,V>
kafka.restore.operators.
ResetPartitionOperator
kafka.restore.
ResetTierPartitionState
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.restore.
RestoreUtil
kafka.tier.backupObjectLifecycle.
RetryFramework
<U,V>
kafka.tier.backupObjectLifecycle.
RetryPolicy
kafka.restore.rpo.
RpoMetricsManager
(implements kafka.tier.
TierReplicaManager.ChangeListener
)
kafka.restore.rpo.
RpoValue
(implements java.lang.
Comparable
<T>)
kafka.restore.schedulers.
S3ObjectStorePool
(implements kafka.restore.schedulers.
ObjectStorePool
)
kafka.tier.store.
S3TierObjectStore
(implements kafka.tier.store.
TierObjectStore
)
kafka.restore.schedulers.
SchedulerUtil
kafka.restore.rpo.
SegmentAndCreateTime
kafka.tier.state.
SegmentState
kafka.restore.operators.
SegmentStateAndPath
kafka.restore.snapshot.
SnapshotObjectStoreUtils
kafka.durability.ondemand.
StartAuditJobRequest
kafka.durability.ondemand.
StartAuditJobResponse
kafka.restore.statemachine.api.
State
kafka.restore.statemachine.
StateMachineController
kafka.tier.backupObjectLifecycle.
StateManager
kafka.tier.backupObjectLifecycle.
StateManagerConfig
kafka.restore.statemachine.
StateTransitionLog
kafka.restore.rest.
StatusResponse
kafka.durability.ondemand.
StopAuditJobRequest
kafka.durability.ondemand.
StopAuditJobResponse
kafka.tools.
StreamsResetter
com.google.flatbuffers.Struct
kafka.durability.events.serdes.
BaseInfo
kafka.tier.serdes.
CompactStats
kafka.durability.serdes.
EpochChain
kafka.durability.db.kraft.serdes.
EpochChainWithLeader
kafka.durability.db.kraft.serdes.
KRaftEpochInfo
kafka.tier.serdes.
OffsetAndEpoch
kafka.tier.serdes.
OffsetRange
kafka.tier.serdes.
OpaqueDataField
kafka.durability.events.controller.serdes.
QuorumVoterFetchOffsetRecord
kafka.tier.serdes.
UUID
com.google.flatbuffers.Table
kafka.durability.db.serdes.
AuditRunInfo
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.broker.serdes.
DeletePartition
kafka.durability.events.broker.serdes.
DeleteRecords
kafka.durability.events.broker.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.broker.serdes.
InjectState
kafka.durability.events.broker.serdes.
IsrExpand
kafka.durability.restore.db.serdes.
Job
kafka.durability.events.controller.serdes.
KRaftHWMChange
kafka.durability.events.controller.serdes.
KRaftLeaderChange
kafka.durability.events.controller.serdes.
KRaftLogSnapshotGeneration
kafka.durability.events.controller.serdes.
KRaftLogStartOffsetChange
kafka.durability.events.controller.serdes.
KRaftNodeStartUp
kafka.durability.db.kraft.serdes.
KRaftPartitionInfo
kafka.durability.db.kraft.serdes.
KRaftQuorumInfo
kafka.backupRestore.objectLifecycle.serdes.
LifecycleManagerState
kafka.tier.serdes.
MaterializationTrackingInfo
kafka.tier.serdes.
MetadataSnapshotUploadComplete
kafka.tier.serdes.
MetadataSnapshotUploadInitiate
kafka.durability.events.broker.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.broker.serdes.
RetentionChange
kafka.tier.serdes.
SegmentDeleteComplete
kafka.tier.serdes.
SegmentDeleteInitiate
kafka.tier.serdes.
SegmentUploadComplete
kafka.tier.serdes.
SegmentUploadInitiate
kafka.tier.serdes.
SnapshotTrackingInfo
kafka.durability.events.broker.serdes.
StartOffsetChange
kafka.tier.serdes.
TierKafkaKey
kafka.tier.serdes.
TierPartitionStateEntry
kafka.tier.serdes.
TierPartitionStateHeader
kafka.tier.serdes.
TierTopicSnapshot
kafka.tier.serdes.
TierTopicSnapshotEntry
kafka.tier.serdes.
TierTopicSnapshotHeader
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
)
org.apache.kafka.server.util.ShutdownableThread
kafka.tier.backupObjectLifecycle.
LifecycleManager
kafka.restore.schedulers.
ThreadPoolMonitor
(implements java.lang.
Runnable
)
java.lang.
Throwable
(implements java.io.
Serializable
)
java.lang.
Exception
kafka.catalog.exceptions.
CollectorContextNotInitializedException
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.durability.exception.
MemoryLimitExceededException
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.tools.
TierPartitionStateRestoreRawInputGenerator.InvalidInputException
kafka.tier.backupObjectLifecycle.
StateManager.LifecycleManagerVersionException
kafka.tier.backupObjectLifecycle.
TierObjectStoreBatchOperationException
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.store.
TierObjectAttribute
kafka.tier.domain.
TierObjectMetadata
kafka.tier.store.
TierObjectStore.BackupObjectsListMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.DurabilityAuditsOffsetMapMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.HealthMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.KeyAndVersion
kafka.tier.store.
TierObjectStore.KRaftSnapshotMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
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.TierPartitionStateSnapshotMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.TierStateRestoreSnapshotMetadata
(implements kafka.tier.store.
TierObjectStore.ObjectStoreMetadata
)
kafka.tier.store.
TierObjectStore.TierTopicSnapshotMetadata
(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.
TierPartitionStateCleanupConfig
kafka.tier.state.
TierPartitionStateFactory
kafka.tier.tools.
TierPartitionStateFencingTrigger
kafka.tier.tools.
TierPartitionStateRestoreRawInputGenerator
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.restore.snapshot.
TierTopicConsumerForRestore
(implements java.lang.
Runnable
)
kafka.tier.client.
TierTopicConsumerSupplier
(implements java.util.function.
Supplier
<T>)
kafka.tier.topic.
TierTopicDataLossValidator
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.tools.
TierTopicPartitionId
kafka.tier.domain.
TierTopicPartitionSnapshot
kafka.tier.client.
TierTopicProducerSupplier
(implements java.util.function.
Supplier
<T>)
kafka.tier.backupObjectLifecycle.
TierTopicReader
kafka.tier.backupObjectLifecycle.
TierTopicReaderConfig
kafka.tier.snapshot.
TierTopicSnapshotManager
(implements java.lang.
Runnable
)
kafka.tier.snapshot.
TierTopicSnapshotMetrics
kafka.tier.snapshot.
TierTopicSnapshotObject
(implements kafka.utils.cloud.
SequencedObject
)
kafka.tier.snapshot.
TierTopicSnapshotObjectStoreUtils
kafka.tier.state.
TierUtils
kafka.restore.configmap.
TopicConfig
kafka.tier.
TopicIdPartition
kafka.catalog.metadata.
TopicInfo
kafka.durability.ondemand.
TopicPartitionConfig
kafka.restore.configmap.
TopicPartitionConfigMapGenerator
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.durability.tools.
UpdateDurabilityDb
kafka.restore.db.
Utils
kafka.tier.tools.
ValidateAndRestoreSegments
kafka.tier.tools.
ValidateFtpsSegmentsResponse
kafka.tier.tools.
ValidateSegments
kafka.tier.store.
VersionInformation
kafka.tier.store.
S3VersionInformation
kafka.assignor.
ZkClusterDescriber
(implements org.apache.kafka.metadata.placement.ClusterDescriber)
kafka.catalog.
ZKMetadataCollector
kafka.catalog.
ZKMetadataCollectorConfig
kafka.catalog.
ZKMetadataCollectorContext
(implements java.lang.
AutoCloseable
)
Interface Hierarchy
kafka.common.
AliveBrokersMetadata
kafka.restore.schedulers.
AsyncServiceSchedulerResultsReceiver
java.lang.
AutoCloseable
org.apache.kafka.image.publisher.MetadataPublisher
kafka.controller.
ClusterBalanceManager
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
java.lang.
Comparable
<T>
kafka.utils.cloud.
SequencedObject
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.catalog.
LocalStore
kafka.restore.
MessageEmitter
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.server.
TierStateMachine
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.
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.store.
BucketHealthResult
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