- abortedTxns - Variable in class kafka.tier.fetcher.TierFetchResult
-
- AbstractAsyncServiceScheduler - Class in kafka.restore.schedulers
-
Abstract asynchronous service scheduler for Restore interaction with external services.
- AbstractAsyncServiceScheduler(AsyncServiceSchedulerResultsReceiver) - Constructor for class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Constructs new AbstractAsyncServiceScheduler.
- AbstractAsyncServiceScheduler(AsyncServiceSchedulerResultsReceiver, int) - Constructor for class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Constructs new AbstractAsyncServiceScheduler.
- AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus - Enum in kafka.restore.schedulers
-
Possible statuses of the AsyncServiceScheduler.
- AbstractTierMetadata - Class in kafka.tier.domain
-
- AbstractTierMetadata() - Constructor for class kafka.tier.domain.AbstractTierMetadata
-
- AbstractTierSegmentMetadata - Class in kafka.tier.domain
-
Represents metadata for a particular segment.
- AbstractTierSegmentMetadata() - Constructor for class kafka.tier.domain.AbstractTierSegmentMetadata
-
- AbstractTransition - Class in kafka.restore.statemachine.transitions
-
- AbstractTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.AbstractTransition
-
- accumulate(CompactStats) - Method in class kafka.tier.state.CompactStats
-
- accumulatedCompactStats() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- accumulatedCompactStats(CompactStats) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- accumulatedCompactStats() - Method in class kafka.tier.state.FileTierPartitionState
-
- accumulatedCompactStats() - Method in class kafka.tier.state.Header
-
- accumulatedCompactStats() - Method in interface kafka.tier.state.TierPartitionState
-
Return the accumulated compaction stats recorded by the TierPartitionState.
- activeKeySha() - Method in class kafka.tier.store.encryption.EncryptionKeyManager
-
Returns the current active KeySha.
- addAccumulatedCompactStats(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addBaseOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addBaseOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addBaseProperties(Properties, String, Integer) - Static method in class kafka.tier.client.TierTopicProducerSupplier
-
- addBlobs(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- addBrokerId(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- addBrokerId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- addChecksum(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- addCommittedStartOffset(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addCompactDirtyStartOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addCompactStats(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addContentHash(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addControllerEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- addCurrentRetentionInDays(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- addDate(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- addDestinationObjectIds(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addDurabilityPartitionsOffsets(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Header
-
- addDurabilityRunId(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Header
-
- addEndOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addEndOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addEndOffsetDelta(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addEndOffsetDelta(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addEndPosition(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- addEndTime(FlatBufferBuilder, long) - Static method in class kafka.durability.restore.db.serdes.Job
-
- addEpochChain(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addErrorOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addExpandBrokerId(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- addExternalLostMessages(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addFirstBatchTimestamp(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addFirstBatchTimestamp(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addFirstOffset(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.EpochChange
-
- addFreezeLogStartOffset(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.PartitionFence
-
- addGlobalMaterializedEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- addGlobalMaterializedOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- addHasAbortedTxns(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addHasAbortedTxns(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addHasEpochState(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addHasEpochState(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addHasProducerState(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addHasProducerState(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addHeader(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- addHeader(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- addHeader(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
-
- addHeader(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Database
-
- addHighWatermark(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addId(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- addId(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- addId(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Job
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EpochChange
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- addInfo(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- addIsr(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- addIsr(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EpochChange
-
- addIsr(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- addIsr(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- addJobs(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Database
-
- addLastCleanOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addLastCompactStats(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addLastRunTimestamp(FlatBufferBuilder, long) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- addLatestDataFiles(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- addLatestFile(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- addLeader(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addListener(TierReplicaManager.ChangeListener) - Method in class kafka.tier.TierReplicaManager
-
Register a change listener.
- addLocalMaterializedEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- addLocalMaterializedOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- addMaterializationInfo(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addMaxTimestamp(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addMaxTimestamp(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionFence
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- addMetadata(String, Object) - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
- addMetadata(String, Object) - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- addMetadata(AbstractTierMetadata) - Method in interface kafka.tier.topic.TierTopicAppender
-
Write an AbstractTierMetadata to the Tier Topic, returning a
CompletableFuture that tracks the result of the materialization after the
message has been read from the tier topic, allowing the sender to determine
whether the write was fenced, or the send failed.
- addMetadata(AbstractTierMetadata) - Method in class kafka.tier.topic.TierTopicManager
-
Write an AbstractTierMetadata to the Tier Topic, returning a
CompletableFuture that tracks the result of the materialization after the
message has been read from the tier topic, allowing the sender to determine
whether the write was fenced, or the send failed.
- addName(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- addObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- addObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- addObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- addObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addOngoingReductionMinDeletionTimestamp(FlatBufferBuilder, long) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- addOpaqueData(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addOpaqueData(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addPartition(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- addPartition(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addPartition(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- addPartition(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addPartition(PartitionConfig) - Method in class kafka.restore.configmap.TopicConfig
-
- addPartition(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- addPartitionCreationOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- addPartitionRestoreContext(PartitionRestoreContext) - Method in class kafka.restore.db.FileRestoreDB
-
- addPartitionRestoreContext(PartitionRestoreContext) - Method in class kafka.restore.db.Job
-
- addPartitionRestoreContext(PartitionRestoreContext) - Method in interface kafka.restore.db.RestoreDB
-
Add a PartitionContext into db
- addPartitionRestoreContexts(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Job
-
- addPartitions(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- addPreviousObjectId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addReceivedResponse(MessageResponse) - Method in interface kafka.restore.messages.MultipleResponseHandler
-
Adds a response of subRequest to the list of received responses.
- addReceivedResponse(MessageResponse) - Method in class kafka.restore.schedulers.RestoreObjectMultipleResponseHandler
-
- addReductionRecordTimestamp(FlatBufferBuilder, long) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- addReplica(NodeConfig) - Method in class kafka.restore.configmap.PartitionConfig
-
- addReplicas(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addRestoreLogStartOffset(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addRestoreOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addRestoreStartTime(FlatBufferBuilder, long) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addRetentionData(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- addRetentionInDays(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- addRetentionSize(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addRetentionTime(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addRetentionType(FlatBufferBuilder, byte) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- addRetentionValue(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- addSize(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaKey
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataKey
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitKey
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitValue
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogKey
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue
-
- addSize(MessageSizeAccumulator, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- addSize(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addSize(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addSourceObjectIds(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addStartOffset(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addStartOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addStartOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addStartTime(FlatBufferBuilder, long) - Static method in class kafka.durability.restore.db.serdes.Job
-
- addState(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addState(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- addStateOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addStatus(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Job
-
- addStatus(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addStatus(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addTierOffsets(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- addTimeForDeletionInMs(FlatBufferBuilder, long) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- addTimeMs(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- addTimeStamp(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- addTopic(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- addTopic(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- addTopic(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- addTopicConfig(TopicConfig) - Method in class kafka.restore.configmap.RestoreTopicListConfig
-
- addTopicId(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addTopicId(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- addTopicId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- addTopicId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- addTopicName(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- addTopicName(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- addTopics(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- addTopics(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
-
- addTotalMessages(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- addTrimmedOffset(FlatBufferBuilder, long) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- addUploadType(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addUploadType(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addVersion(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- addVersion(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Header
-
- addVersion(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Header
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.InitLeader
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionFence
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- Adler32CheckedFileIO - Class in kafka.utils.checksum
-
Adler32CheckedFileIO is an I/O package which extends CheckedFileIO and is used for ChecksumAlgorithm type ADLER.
- Adler32WithInPlaceUpdate - Class in kafka.utils.checksum
-
Adler32WithInPlaceUpdate is an implementation of ChecksumWithInPlaceUpdate class which provides checksum
functionality using Adler32 algorithm.
- Adler32WithInPlaceUpdate() - Constructor for class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
Creates a new Adler32WithInPlaceUpdate object
- ADLER_SUPER_BLOCK_LENGTH_MAX - Static variable in class kafka.utils.checksum.Adler32CheckedFileIO
-
The maximum super block length supported for algorithm ADLER.
- Algorithm - Enum in kafka.utils.checksum
-
Types of checksum algorithms supported
- AliveBrokersSnapshot - Class in kafka.common
-
A snapshot of the Kafka brokers that are online,
their latest epochs and information as to whether they are excluded for replica placements.
- AliveBrokersSnapshot(Map<Integer, Long>, Set<Integer>, Set<Integer>) - Constructor for class kafka.common.AliveBrokersSnapshot
-
- allStates() - Static method in class kafka.restore.statemachine.api.State
-
- apiKey() - Method in class kafka.internals.generated.ComputedQuotaKey
-
- apiKey() - Method in class kafka.internals.generated.ComputedQuotaValue
-
- apiKey() - Method in class kafka.internals.generated.GroupMetadataKey
-
- apiKey() - Method in class kafka.internals.generated.GroupMetadataValue
-
- apiKey() - Method in class kafka.internals.generated.OffsetCommitKey
-
- apiKey() - Method in class kafka.internals.generated.OffsetCommitValue
-
- apiKey() - Method in class kafka.internals.generated.TransactionLogKey
-
- apiKey() - Method in class kafka.internals.generated.TransactionLogValue
-
- append(AbstractTierMetadata, OffsetAndEpoch) - Method in class kafka.tier.state.FileTierPartitionState
-
- append(AbstractTierMetadata, OffsetAndEpoch) - Method in interface kafka.tier.state.TierPartitionState
-
Appends abstract metadata to the tier partition.
- append(ByteBuffer) - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
Append a buffer at the end and updates the checksum value
- append(ByteBuffer) - Method in interface kafka.utils.checksum.ChecksumWithInPlaceUpdate
-
Appends a buffer at the end and updates the checksum
- assignment() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- assumeRoleArn - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- AsyncServiceSchedulerResultsReceiver - Interface in kafka.restore.schedulers
-
Interface for receiving results from Asynchronous Service Schedulers.
- AsyncTaskRequest - Class in kafka.restore.messages
-
Abstract AsyncTaskRequest class containing common fields for all AsyncTaskScheduler requests.
- AsyncTaskRequest(int, String, int, String) - Constructor for class kafka.restore.messages.AsyncTaskRequest
-
Constructs new AsyncTaskRequest.
- AsyncTaskResponse - Class in kafka.restore.messages
-
- AsyncTaskResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.AsyncTaskResponse
-
Constructs new AsyncTaskResponse for successful request.
- AsyncTaskScheduler - Class in kafka.restore.schedulers
-
AsyncTaskScheduler for scheduling compute / local I/O intensive tasks.
- AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver, int, RestorePartitionOperatorFactory) - Constructor for class kafka.restore.schedulers.AsyncTaskScheduler
-
Constructs new AsyncTaskScheduler with given pool size.
- AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver, int, RestorePartitionOperatorFactory, int) - Constructor for class kafka.restore.schedulers.AsyncTaskScheduler
-
Constructs new AsyncTaskScheduler with given pool size.
- AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver, RestorePartitionOperatorFactory, int) - Constructor for class kafka.restore.schedulers.AsyncTaskScheduler
-
Constructs new AsyncTaskScheduler, calculating ideal pool size from number of available cores.
- AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver, RestorePartitionOperatorFactory, int, int) - Constructor for class kafka.restore.schedulers.AsyncTaskScheduler
-
Constructs new AsyncTaskScheduler, calculating ideal pool size from number of available cores.
- attributes() - Method in class kafka.common.TopicPlacement.Replica
-
- AutoAbortingGenericInputStream - Class in kafka.tier.store
-
An input stream wrapper which decides to close or abort an InputStream based on
the remaining data left in the stream.
- available() - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- azureBlobPrefix - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
-
- AzureBlockBlobTierObjectStore - Class in kafka.tier.store
-
- AzureBlockBlobTierObjectStore(AzureBlockBlobTierObjectStoreConfig) - Constructor for class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- AzureBlockBlobTierObjectStoreConfig - Class in kafka.tier.store
-
- AzureBlockBlobTierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
-
- azureCredentialsConfig - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
-
- CachedFetchOffsetMetadata - Class in kafka.tier.fetcher.offsetcache
-
- CachedFetchOffsetMetadata(FetchOffsetMetadata, long) - Constructor for class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
-
- cancel() - Method in class kafka.tier.fetcher.CancellationContext
-
Cancel this CancellationContext, causing all
sub-CancellationContexts to cancel.
- cancel() - Method in class kafka.tier.fetcher.PendingFetch
-
Cancel the pending fetch.
- cancel() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
Cancel the request
- cancel(Exception) - Method in interface kafka.tier.state.FileTierPartitionState.MaterializationListener
-
Complete this MaterializationListener without a result.
- cancel(Exception) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.Initialization
-
- cancel(Exception) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.LeaderEpoch
-
- cancel(Exception) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- cancel(Exception) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- CancellationContext - Class in kafka.tier.fetcher
-
A tree to notify processes of cancellation in a thread safe way.
- cancelTracked(AbstractTierMetadata) - Method in class kafka.tier.topic.TierTopicConsumer
-
Cancel materialization tracking for provided metadata.
- canTransitionTo(TierObjectMetadata.State) - Method in enum kafka.tier.domain.TierObjectMetadata.State
-
Check if we can safely transition to the given state.
- checkedFileIO() - Method in class kafka.tier.state.FileTierPartitionState
-
- CheckedFileIO - Class in kafka.utils.checksum
-
CheckedFileIO is an IO wrapper package built on top of FileChannel intended to provide FileChannel supported
operations to end caller with additional checksum capabilities on the data.
- CheckedFileIOHeader - Class in kafka.tier.serdes
-
- CheckedFileIOHeader() - Constructor for class kafka.tier.serdes.CheckedFileIOHeader
-
- checkInvariants() - Method in class kafka.tier.state.FileTierPartitionState
-
Checks invariants for the tier state and throws an IllegalStateException if any are violated.
- checksum() - Method in class kafka.tier.serdes.CheckedFileIOHeader
-
- checksum() - Method in class kafka.utils.checksum.CheckedFileIO
-
Optionally return the checksum value.
- CHECKSUM_ENABLED - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- CHECKSUM_ENABLED_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- ChecksumMigration - Class in kafka.tier.state
-
- ChecksumMigration() - Constructor for class kafka.tier.state.ChecksumMigration
-
- ChecksumWithInPlaceUpdate - Interface in kafka.utils.checksum
-
ChecksumWithInPlaceUpdate is an extension of the Checksum interface with provision of additional method
`append` and `inPlaceUpdate`.
- choice() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- cleanup() - Method in class kafka.tier.topic.TierTopicConsumer
-
- CLEANUP_POLICY - Static variable in class kafka.restore.configmap.ConfigmapUtil
-
- clear() - Method in class kafka.tier.store.encryption.EncryptionKeyManager
-
Clear the key cache, this is used only for testing.
- clearForClusterId() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- CleartextDataKey - Class in kafka.tier.store.encryption
-
A decrypted data encryption key stored in the raw AES256_GCM format.
- cleartextDataKey - Variable in class kafka.tier.store.encryption.KeyContext
-
- client(S3TierObjectStoreConfig) - Static method in class kafka.tier.store.S3TierObjectStore
-
- clientHost() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- clientId() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- clientId(String, int, long) - Static method in class kafka.tier.client.TierTopicProducerSupplier
-
- clientIdPrefix(String) - Static method in class kafka.tier.client.TierTopicClient
-
Client id prefix to use for tier topic clients.
- close() - Method in class kafka.restore.operators.FtpsSegmentView
-
- close() - Method in class kafka.tier.fetcher.CancellationContext
-
- close() - Method in class kafka.tier.fetcher.MemoryTracker
-
- close() - Method in class kafka.tier.fetcher.TierFetcher
-
Seal the TierFetcher from accepting new fetches, and cancel all in-progress fetches.
- close() - Method in class kafka.tier.fetcher.TierStateFetcher
-
- close() - Method in class kafka.tier.state.FileTierPartitionState
-
- close() - Method in interface kafka.tier.state.TierPartitionState
-
Close TierPartition, flushing to disk.
- close() - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- close() - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- close() - Method in class kafka.tier.store.encryption.EncryptionKeyManager
-
- close() - Method in class kafka.tier.store.GcsTierObjectStore
-
- close() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- close() - Method in class kafka.tier.store.S3TierObjectStore
-
- close() - Method in interface kafka.tier.store.TierObjectStore
-
- close() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- close() - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- close() - Method in interface kafka.tier.store.TierObjectStoreResponse
-
- close() - Method in class kafka.tier.tools.TierMetadataComparator
-
As part of the closeable contract, this method will cleanup all the open resources such as backend stores
as well as cancel any long-running existing verification tasks
- close() - Method in class kafka.tier.tools.TierMetadataValidator
-
This method will be primarily used to clean up resources including various backends
- close() - Method in class kafka.tier.topic.TierMessageFormatter
-
- close() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- close() - Method in class kafka.utils.checksum.CheckedFileIO
-
Closes the file channel
- close() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- closeHandlers() - Method in class kafka.tier.state.FileTierPartitionState
-
- closeHandlers() - Method in interface kafka.tier.state.TierPartitionState
-
- CLOUD_PROVIDER - Static variable in class kafka.restore.RestoreConfig
-
- CLUSTER_ID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- CLUSTER_ID_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- ClusterBalanceManager - Interface in kafka.controller
-
- clusterBalanceManager(KafkaConfig) - Static method in interface kafka.controller.ClusterBalanceManager
-
Instantiate the ClusterBalanceManager based on the config
- clusterId - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- clusterId() - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- clusterId() - Method in class kafka.tier.store.TierObjectStore.LifecycleManagerStateMetadata
-
- clusterId - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- clusterIdOpt - Variable in class kafka.tier.store.TierObjectStoreConfig
-
- commitIntervalMs - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- committedEndOffset() - Method in class kafka.tier.state.FileTierPartitionState
-
- committedEndOffset() - Method in interface kafka.tier.state.TierPartitionState
-
Return the end offset spanned by the TierPartitionState that has been committed to disk.
- committedStartOffset() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- commitTimestamp() - Method in class kafka.internals.generated.OffsetCommitValue
-
- COMPACT - Static variable in class kafka.restore.configmap.ConfigmapUtil
-
- compactDirtyStartOffset() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- compactDirtyStartOffset() - Method in class kafka.tier.state.FileTierPartitionState
-
- compactDirtyStartOffset() - Method in class kafka.tier.state.Header
-
- compactDirtyStartOffset() - Method in interface kafka.tier.state.TierPartitionState
-
Return the compaction dirty start offset checkpoint recorded by the TierPartitionState.
- compactedSegments() - Method in class kafka.tier.state.FileTierPartitionState
-
- compactedSegments() - Method in interface kafka.tier.state.TierPartitionState
-
- CompactionCommitAndSwap - Class in kafka.tier.serdes
-
- CompactionCommitAndSwap() - Constructor for class kafka.tier.serdes.CompactionCommitAndSwap
-
- compactStats() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- compactStats() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- compactStats(CompactStats) - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- CompactStats - Class in kafka.tier.serdes
-
- CompactStats() - Constructor for class kafka.tier.serdes.CompactStats
-
- CompactStats - Class in kafka.tier.state
-
- CompactStats(long, long, long) - Constructor for class kafka.tier.state.CompactStats
-
- CompactStats(CompactStats) - Constructor for class kafka.tier.state.CompactStats
-
- ComparatorInfo - Class in kafka.tier.tools.common
-
This class will act as a placeholder class for all the DAOs that will be used by TierMetadataComparator tool
All of the inner classes follow the specific pattern in terms of accessors:
1.
- ComparatorInfo.ComparatorOutput - Class in kafka.tier.tools.common
-
This class represents a single output from the Comparator tool
For every fenced topic partition details, we would generate one such distinct output object
- ComparatorInfo.ComparatorReplicaInfo - Class in kafka.tier.tools.common
-
This class represents the replica info which is the core unit of the comparator tool
For every n fenced topic details and m bootstrap server, there should be n*(m+1) replicas
The +1 is because we would also generate one replica directly from rematerialized events
- ComparatorOutput(Map<String, ComparatorInfo.ComparatorReplicaInfo>, ComparatorInfo.ComparatorReplicaInfo, FenceEventInfo) - Constructor for class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- ComparatorReplicaInfo(String, Path, TopicIdPartition) - Constructor for class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- ComparatorReplicaInfo(String, String, String, boolean) - Constructor for class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- comparesStates(Path, Path) - Method in class kafka.tier.tools.TierMetadataValidator
-
Compares the 'actual' state file with 'expected' state file.
- COMPARISON_TOOL_INPUT - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_INPUT_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_OUTPUT - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_OUTPUT_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- CompletableFutureRetryer - Class in kafka.restore.schedulers
-
- CompletableFutureRetryer(ThreadPoolExecutor, Duration) - Constructor for class kafka.restore.schedulers.CompletableFutureRetryer
-
Util to help run retry
Currently, it only supports fixed-wait-time retry strategy
todo: need to enhance to support other retry strategy in the future.
- complete(FileTierPartitionState.State) - Method in interface kafka.tier.state.FileTierPartitionState.MaterializationListener
-
Try to complete this listener.
- complete(FileTierPartitionState.State) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.Initialization
-
- complete(FileTierPartitionState.State) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.LeaderEpoch
-
- complete(FileTierPartitionState.State) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- complete(FileTierPartitionState.State) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- completeCatchup() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
- completedCount() - Method in class kafka.restore.statemachine.StateMachineController
-
- completeExceptionally(TopicPartition, Exception) - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
Complete a TimestampAndOffset request exceptionally.
- computeAssignmentForExistingTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in interface kafka.assignor.TopicReplicaAssignor
-
Computes the replica assignment for an existing topic that is about to have new partitions created on it (CreatePartitions request).
- computeAssignmentForNewTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in interface kafka.assignor.TopicReplicaAssignor
-
Computes the replica assignment for a topic that's about to be created (CreateTopics request).
- ComputedBrokerQuota(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- ComputedBrokerQuota() - Constructor for class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- computedBrokerQuotas() - Method in class kafka.internals.generated.ComputedQuotaValue
-
- ComputedQuota(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- ComputedQuota() - Constructor for class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- ComputedQuotaKey - Class in kafka.internals.generated
-
- ComputedQuotaKey(Readable, short) - Constructor for class kafka.internals.generated.ComputedQuotaKey
-
- ComputedQuotaKey(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.ComputedQuotaKey
-
- ComputedQuotaKey() - Constructor for class kafka.internals.generated.ComputedQuotaKey
-
- ComputedQuotaKey.EntityData - Class in kafka.internals.generated
-
- computedQuotas() - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- ComputedQuotaValue - Class in kafka.internals.generated
-
- ComputedQuotaValue(Readable, short) - Constructor for class kafka.internals.generated.ComputedQuotaValue
-
- ComputedQuotaValue(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.ComputedQuotaValue
-
- ComputedQuotaValue() - Constructor for class kafka.internals.generated.ComputedQuotaValue
-
- ComputedQuotaValue.ComputedBrokerQuota - Class in kafka.internals.generated
-
- ComputedQuotaValue.ComputedQuota - Class in kafka.internals.generated
-
- computeMd5(CheckedFileIO) - Static method in class kafka.restore.operators.OperatorUtil
-
- ConfigmapUtil - Class in kafka.restore.configmap
-
- ConfigmapUtil() - Constructor for class kafka.restore.configmap.ConfigmapUtil
-
- configure(Map<String, ?>) - Method in class kafka.metrics.KafkaYammerMetrics
-
- configuredNumPartitions - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- configuredReplicationFactor - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- Constants - Class in kafka.restore.schedulers
-
- Constants() - Constructor for class kafka.restore.schedulers.Constants
-
- Constants - Class in kafka.restore.statemachine
-
- Constants() - Constructor for class kafka.restore.statemachine.Constants
-
- constraints() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- consumer - Variable in class kafka.tier.tools.TierTopicMaterializationUtils
-
- consumerLagMetric - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerMetrics
-
- container - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
-
- containsRequiredFiles(Map<String, String>) - Static method in class kafka.restore.schedulers.ListVersionsOperator
-
Verify version map must contain required file types
- CONTENT_HASH_PARAM_NAME - Static variable in class kafka.restore.schedulers.Constants
-
- contentHash() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- contentHash() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- contentHashAsByteBuffer() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- contentHashInByteBuffer(ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
-
- controllerEpoch() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- convertStringToTimestamp(String) - Static method in class kafka.restore.configmap.ConfigmapUtil
-
convert input string to a timestamp (long)
- convertToDateKey(Long) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Utility method to convert the time in milliseconds to date in a common format defined by LifecycleManager.DATE_PATTERN
- CopyObjectInStoreRequest - Class in kafka.restore.messages
-
Request of restoring an object by copying from specified version in object store.
- CopyObjectInStoreRequest(int, String, int, UUID, String, String) - Constructor for class kafka.restore.messages.CopyObjectInStoreRequest
-
Constructs new RestoreObjectsInStoreRequest.
- CopyObjectInStoreResponse - Class in kafka.restore.messages
-
- CopyObjectInStoreResponse(int, String, int, int, MessageStatusCode, MessageResult, UUID, String) - Constructor for class kafka.restore.messages.CopyObjectInStoreResponse
-
Constructs new RestoreObjectsInStoreResponse.
- CopyObjectOperator - Class in kafka.restore.schedulers
-
- CopyObjectOperator(CopyObjectInStoreRequest, MultipleResponseHandler, TierObjectStore, ThreadPoolExecutor) - Constructor for class kafka.restore.schedulers.CopyObjectOperator
-
- count() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- crc32c(ByteBuffer) - Static method in class kafka.tier.store.GcsTierObjectStore
-
- create(Path, Algorithm, short) - Static method in class kafka.utils.checksum.CheckedFileIO
-
Create a new file based on the algorithm passed as parameter.
- createBackupObjectsMetadata(FlatBufferBuilder, int, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- createBaseInfo(FlatBufferBuilder, int, int, long, long) - Static method in class kafka.durability.events.serdes.BaseInfo
-
- createBlobMetadata(FlatBufferBuilder, int, long, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- createBlobsVector(FlatBufferBuilder, int[]) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- createCheckedFileIOHeader(FlatBufferBuilder, byte, long, long) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- createCompactStats(FlatBufferBuilder, long, long, long) - Static method in class kafka.tier.serdes.CompactStats
-
- createDatabase(FlatBufferBuilder, int, int) - Static method in class kafka.durability.db.serdes.Database
-
- createDatabase(FlatBufferBuilder, int, int) - Static method in class kafka.durability.restore.db.serdes.Database
-
- createDatedList(FlatBufferBuilder, int, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- createDurabilityPartitionsOffsetsVector(FlatBufferBuilder, long[]) - Static method in class kafka.durability.db.serdes.Header
-
- createEpochChain(FlatBufferBuilder, int, long) - Static method in class kafka.durability.db.serdes.EpochChain
-
- createEventKey(FlatBufferBuilder, int, int, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- createHeader(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- createHeader(FlatBufferBuilder, int, int, int) - Static method in class kafka.durability.db.serdes.Header
-
- createHeader(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Header
-
- createIsrVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- createIsrVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.events.serdes.EpochChange
-
- createIsrVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- createIsrVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- createJob(FlatBufferBuilder, int, int, long, long, int) - Static method in class kafka.durability.restore.db.serdes.Job
-
- createJobsVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.restore.db.serdes.Database
-
- createLatestDataFilesVector(FlatBufferBuilder, int[]) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- createLifecycleManagerState(FlatBufferBuilder, int, long, int, int, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- createMaterializationTrackingInfo(FlatBufferBuilder, long, long, int, int) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- createOffsetAndEpoch(FlatBufferBuilder, long, int) - Static method in class kafka.tier.serdes.OffsetAndEpoch
-
- createOpaqueDataField(FlatBufferBuilder, long, long, long, long) - Static method in class kafka.tier.serdes.OpaqueDataField
-
- createPartitionInfo(FlatBufferBuilder, int, long, long, long, long, long, long, long, int, int) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- createPartitionRestoreContext(FlatBufferBuilder, int, int, int, int, long, int, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- createPartitionRestoreContextsVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.restore.db.serdes.Job
-
- createPartitionsVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- createReplicasVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- createRetentionDataVector(FlatBufferBuilder, int[]) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- createTierOffsetsVector(FlatBufferBuilder, long[]) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- createTierTopicProducer(Properties, String) - Static method in class kafka.tier.tools.RecoveryUtils
-
Create and return a new TierTopic Producer object.
- createTierTopicReader(List<Long>) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- createTimeMs() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- createTopicInfo(FlatBufferBuilder, int, int) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- createTopicMetadata(FlatBufferBuilder, int, int, int, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- createTopicRetentionData(FlatBufferBuilder, int, int, long, long) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- createTopicsVector(FlatBufferBuilder, int[]) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- createTopicsVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.db.serdes.Database
-
- createUUID(FlatBufferBuilder, long, long) - Static method in class kafka.tier.serdes.UUID
-
- createWithEmptyClusterIdBrokerId(String, String, String, Integer, String, String, Duration) - Static method in class kafka.tier.store.GcsTierObjectStoreConfig
-
- creationTimeMs() - Method in class kafka.common.BrokerAdditionDescriptionInternal
-
- CURRENT_VERSION - Static variable in class kafka.tier.domain.TierSegmentUploadComplete
-
- CURRENT_VERSION - Static variable in class kafka.tier.domain.TierSegmentUploadInitiate
-
- CURRENT_VERSION - Static variable in class kafka.tier.TierTopicManagerCommitter
-
- currentJob() - Method in class kafka.restore.db.FileRestoreDB
-
- currentJob() - Method in interface kafka.restore.db.RestoreDB
-
get current job
- currentRetentionInDays() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- currentState() - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
- currentState() - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- currentStateTimestamp() - Method in class kafka.internals.generated.GroupMetadataValue
-
- currentStatus() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
-
- currentStatusLastUpdateTimeMs() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
-
- customLifecycleManagerEnabled - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- customLifecycleManagerFrequencyInMs - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- f0() - Method in class kafka.tier.serdes.OpaqueDataField
-
- f1() - Method in class kafka.tier.serdes.OpaqueDataField
-
- f2() - Method in class kafka.tier.serdes.OpaqueDataField
-
- f3() - Method in class kafka.tier.serdes.OpaqueDataField
-
- FAILED - Static variable in class kafka.restore.statemachine.api.State
-
- failedCount() - Method in class kafka.restore.statemachine.StateMachineController
-
- failureMetric - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerMetrics
-
- FENCE_EVENT_SENT - Static variable in class kafka.restore.statemachine.api.State
-
- FENCE_EVENT_URI_PATH - Static variable in class kafka.restore.schedulers.Constants
-
- FENCE_TARGET_PARTITIONS_CONFIG_FILE - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- FENCE_TARGET_PARTITIONS_CONFIG_FILE_DOC - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- FENCE_TARGET_PARTITIONS_CONFIG_FILE_FORMAT - Static variable in class kafka.tier.tools.RecoveryUtils
-
- FENCE_TRIGGER_OUTPUT_FILE - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- FENCE_TRIGGER_OUTPUT_FILE_DOC - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- fencedSegments() - Method in class kafka.tier.state.FileTierPartitionState
-
- fencedSegments() - Method in interface kafka.tier.state.TierPartitionState
-
- FenceEventInfo - Class in kafka.tier.tools.common
-
Encapsulates information related to a fencing event.
- FenceEventInfo(String, String, int, String, Boolean, long, int, long) - Constructor for class kafka.tier.tools.common.FenceEventInfo
-
- fenceEventInfo() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- FenceEventSentToPartitionFencedTransition - Class in kafka.restore.statemachine.transitions
-
- FenceEventSentToPartitionFencedTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FenceEventSentToPartitionFencedTransition
-
- fetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>, int) - Method in class kafka.tier.fetcher.TierFetcher
-
Execute a read for a single partition from Tiered Storage.
- FETCH_FTPS_URI_PATH - Static variable in class kafka.restore.schedulers.Constants
-
- FetchKey - Class in kafka.tier.fetcher.offsetcache
-
- FetchKey(UUID, long) - Constructor for class kafka.tier.fetcher.offsetcache.FetchKey
-
- fetchLeaderEpochStateAsync(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.fetcher.TierStateFetcher
-
Send a request to the tier state fetcher executor, returning a future that will be
completed when the request has read the tier state from the object store.
- FetchOffsetCache - Class in kafka.tier.fetcher.offsetcache
-
The FetchOffsetCache caches known byte offset and record batch sizes in tiered segments.
- FetchOffsetCache(Time, int, int) - Constructor for class kafka.tier.fetcher.offsetcache.FetchOffsetCache
-
- fetchOffsetForTimestamp(Map<TopicPartition, TierUnfetchedTimestampAndOffset>, Consumer<DelayedOperationKey>) - Method in class kafka.tier.fetcher.TierFetcher
-
- FetchOffsetMetadata - Class in kafka.tier.fetcher.offsetcache
-
- FetchOffsetMetadata(int, OptionalInt) - Constructor for class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
-
- fetchOffsetPositionForStartingOffset(CancellationContext, TierObjectStore, TierObjectStore.ObjectMetadata, long) - Static method in class kafka.tier.fetcher.OffsetIndexFetchRequest
-
Find an OffsetPosition from a OffsetIndex InputStream.
- fetchPartitionStatus() - Method in class kafka.restore.schedulers.PartitionStatusFetcher
-
Send Kafka request to fetch Partition Status asynchronously.
- fetchProducerStateSnapshotAsync(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.fetcher.TierStateFetcher
-
- fetchPropertiesFromArgs(String[]) - Static method in class kafka.tier.tools.TierMetadataDebugger
-
- fetchRecoverSnapshot(TierObjectStore.TierStateRestoreSnapshotMetadata) - Method in class kafka.tier.fetcher.TierStateFetcher
-
- fetchWellKnownPathMetadata() - Method in interface kafka.tier.store.encryption.EncryptionKeyManager.WellKnownKeypathHook
-
Fetches the object metadata at the TierObjectStore-specific "well-known" path.
- filePosition() - Method in class kafka.tier.state.SegmentState
-
- FileRestoreDB - Class in kafka.restore.db
-
- FileRestoreDB() - Constructor for class kafka.restore.db.FileRestoreDB
-
- FileRestoreDB(List<Job>) - Constructor for class kafka.restore.db.FileRestoreDB
-
- FileTierPartitionIterator - Class in kafka.tier.state
-
- FileTierPartitionIterator(TopicIdPartition, CheckedFileIO, long) - Constructor for class kafka.tier.state.FileTierPartitionIterator
-
- FileTierPartitionState - Class in kafka.tier.state
-
Important: this code is performance sensitive.
- FileTierPartitionState(File, LogDirFailureChannel, TopicPartition, boolean, Scheduler, boolean, boolean) - Constructor for class kafka.tier.state.FileTierPartitionState
-
- FileTierPartitionState.MaterializationListener - Interface in kafka.tier.state
-
- FileTierPartitionState.MaterializationListener.Initialization - Class in kafka.tier.state
-
Listener for materialization to reach or surpass a minimum leader epoch.
- FileTierPartitionState.MaterializationListener.LeaderEpoch - Class in kafka.tier.state
-
Listener for materialization to reach or surpass a particular leader epoch.
- FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId - Class in kafka.tier.state
-
Listener for materialization to witness a particular objectId at an FileTierPartitionState restore epoch
equal to or greater than the provided target restore epoch.
- FileTierPartitionState.MaterializationListener.ReplicationTargetOffset - Class in kafka.tier.state
-
Listener for materialization to reach or surpass a particular offset.
- FileTierPartitionStateUtils - Class in kafka.tier.state
-
- FileTierPartitionStateUtils() - Constructor for class kafka.tier.state.FileTierPartitionStateUtils
-
- FilteringJmxReporter - Class in kafka.metrics
-
- FilteringJmxReporter(MetricsRegistry, Predicate<MetricName>) - Constructor for class kafka.metrics.FilteringJmxReporter
-
- filterTo(TopicPartition, MemoryRecords.RecordFilter, ByteBuffer, int, BufferSupplier) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- findMaxSegmentState(Map<UUID, SegmentState>) - Static method in class kafka.restore.operators.OperatorUtil
-
Find the Max segment in the given segment map.
- finish() - Method in class kafka.tier.fetcher.PendingFetch
-
Block on a fetch request finishing (or canceling), returning either complete MemoryRecords
for the fetch, or empty records.
- finishBackupObjectsMetadataBuffer(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- finishCheckedFileIOHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- finishCompactionCommitAndSwapBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- finishDatabaseBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
-
- finishDeletePartitionBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- finishDeleteRecordsBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- finishEpochChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EpochChange
-
- finishEventKeyBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- finishHealthCheckBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- finishInitLeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- finishIsrExpandBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- finishLifecycleManagerStateBuffer(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- finishOffsetChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- finishPartitionDeleteCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- finishPartitionDeleteInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- finishPartitionDeletePreInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- finishPartitionFenceBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionFence
-
- finishPartitionForceRestoreBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- finishPartitionUnfreezeLogStartOffsetBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- finishRetentionChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- finishSegmentDeleteCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- finishSegmentDeleteInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- finishSegmentUploadCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- finishSegmentUploadInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- finishSizePrefixedBackupObjectsMetadataBuffer(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- finishSizePrefixedCheckedFileIOHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- finishSizePrefixedCompactionCommitAndSwapBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- finishSizePrefixedDatabaseBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
-
- finishSizePrefixedDeletePartitionBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- finishSizePrefixedDeleteRecordsBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- finishSizePrefixedEpochChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EpochChange
-
- finishSizePrefixedEventKeyBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
-
- finishSizePrefixedHealthCheckBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- finishSizePrefixedInitLeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
-
- finishSizePrefixedIsrExpandBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- finishSizePrefixedLifecycleManagerStateBuffer(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- finishSizePrefixedOffsetChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- finishSizePrefixedPartitionDeleteCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- finishSizePrefixedPartitionDeleteInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- finishSizePrefixedPartitionDeletePreInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- finishSizePrefixedPartitionFenceBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionFence
-
- finishSizePrefixedPartitionForceRestoreBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- finishSizePrefixedPartitionUnfreezeLogStartOffsetBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- finishSizePrefixedRetentionChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- finishSizePrefixedSegmentDeleteCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- finishSizePrefixedSegmentDeleteInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- finishSizePrefixedSegmentUploadCompleteBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- finishSizePrefixedSegmentUploadInitiateBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- finishSizePrefixedStartOffsetChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- finishSizePrefixedTierKafkaKeyBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- finishSizePrefixedTierPartitionStateEntryBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- finishSizePrefixedTierPartitionStateHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- finishStartOffsetChangeBuffer(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- finishTierKafkaKeyBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- finishTierPartitionStateEntryBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- finishTierPartitionStateHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- FiniteStateMachine - Interface in kafka.restore.statemachine.api
-
- FiniteStateMachineException - Exception in kafka.restore.statemachine.api
-
- FiniteStateMachineException(Transition, Event, Throwable) - Constructor for exception kafka.restore.statemachine.api.FiniteStateMachineException
-
- fire(Event) - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
- fire(Event) - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- firstBatch() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- firstBatchSize() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- firstBatchTimestamp() - Method in class kafka.tier.domain.TierObjectMetadata
-
- firstBatchTimestamp() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- firstBatchTimestamp() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- firstBatchTimestamp() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- firstBatchTimestamp() - Method in class kafka.tier.state.SegmentState
-
- firstNewPartition() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
The partition index from which each subsequent partition is newly-created.
- firstOffset() - Method in class kafka.durability.events.serdes.EpochChange
-
- firstValidOffset - Variable in class kafka.tier.tools.TierMetadataValidator.OffsetValidationResult
-
- flush() - Method in class kafka.tier.state.FileTierPartitionState
-
- flush() - Method in interface kafka.tier.state.TierPartitionState
-
Flush data contained in this TierPartitionState to disk.
- flush() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- flush() - Method in class kafka.utils.checksum.CheckedFileIO
-
Flush method is used to flush the file onto storage.
- flush() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- flushedPath() - Method in class kafka.tier.state.FileTierPartitionState
-
- followerRestorePoint(long) - Method in class kafka.tier.state.FileTierPartitionState
-
Fetch and return the FollowerRestorePoint for the given localLogStartOffset.
- followerRestorePoint(long) - Method in interface kafka.tier.state.TierPartitionState
-
Get the TierObjectMetadata for the immediate previous segment (even beyond retention) to the target startOffset.
- FORCE_RESTORE_EVENT_SENT - Static variable in class kafka.restore.statemachine.api.State
-
- FORCE_RESTORE_EVENT_URI_PATH - Static variable in class kafka.restore.schedulers.Constants
-
- forceMutateState(TierObjectMetadata.State) - Method in class kafka.tier.domain.TierObjectMetadata
-
To mutate state without canTransitionTo rules checking.
- ForceRestoreEventSentToPartitionRestoredTransition - Class in kafka.restore.statemachine.transitions
-
- ForceRestoreEventSentToPartitionRestoredTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.ForceRestoreEventSentToPartitionRestoredTransition
-
- forceRestoreState(TierPartitionForceRestore, ByteBuffer, TierPartitionStatus, OffsetAndEpoch) - Method in class kafka.tier.state.FileTierPartitionState
-
Performs a TierPartitionState restore, swapping the current state file
from buffer and replacing any internal state with the contents of the new TierPartitionState,
setting the TierPartitionStatus of the state to status.
- forceShutdown() - Method in class kafka.restore.RestoreOrchestrator
-
Force shutdown Restore Orchestrator
- freezeLogStartOffset() - Method in class kafka.tier.domain.TierPartitionFence
-
- freezeLogStartOffset() - Method in class kafka.tier.serdes.PartitionFence
-
- freezeMergedLogStartOffset - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- freezeMergedLogStartOffset() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- fromByte(byte) - Static method in enum kafka.tier.domain.TierUploadType
-
- fromByte(byte) - Static method in enum kafka.tier.state.TierPartitionStatus
-
- fromByteArray(byte[]) - Static method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- fromLongArray(long[]) - Static method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- fromRawBytes(byte[]) - Static method in class kafka.tier.store.encryption.KeySha
-
- FTPS_FETCHED - Static variable in class kafka.restore.statemachine.api.State
-
- FTPS_RECONCILED - Static variable in class kafka.restore.statemachine.api.State
-
- FTPS_REPAIRED - Static variable in class kafka.restore.statemachine.api.State
-
- FTPS_UPLOADED - Static variable in class kafka.restore.statemachine.api.State
-
- FtpsFetchedToFtpsRepairedTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsFetchedToFtpsRepairedTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsFetchedToFtpsRepairedTransition
-
- FtpsFetchedToPartitionRestoredTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsFetchedToPartitionRestoredTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsFetchedToPartitionRestoredTransition
-
- FtpsReconciledToFtpsUploadedTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsReconciledToFtpsUploadedTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsReconciledToFtpsUploadedTransition
-
- FtpsRepairedToFtpsReconciledTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsRepairedToFtpsReconciledTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsRepairedToFtpsReconciledTransition
-
- FtpsRepairedToSegmentsRepairedTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsRepairedToSegmentsRepairedTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsRepairedToSegmentsRepairedTransition
-
- FtpsSegmentView - Class in kafka.restore.operators
-
A partition restore includes 3 phases:
1.
- FtpsSegmentView(TopicPartition, File, long) - Constructor for class kafka.restore.operators.FtpsSegmentView
-
- FtpsUploadedToForceRestoreEventSentTransition - Class in kafka.restore.statemachine.transitions
-
- FtpsUploadedToForceRestoreEventSentTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.FtpsUploadedToForceRestoreEventSentTransition
-
- gcsBucket - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- gcsCredFilePath - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- gcsPrefix - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- gcsRegion - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- gcsSseCustomerEncryptionKey - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- GcsTierObjectStore - Class in kafka.tier.store
-
- GcsTierObjectStore(Time, GcsTierObjectStoreConfig) - Constructor for class kafka.tier.store.GcsTierObjectStore
-
- GcsTierObjectStore(Time, Metrics, GcsTierObjectStoreConfig) - Constructor for class kafka.tier.store.GcsTierObjectStore
-
- GcsTierObjectStoreConfig - Class in kafka.tier.store
-
- GcsTierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.GcsTierObjectStoreConfig
-
- GcsTierObjectStoreConfig(Optional<String>, Optional<Integer>, String, String, String, Integer, String, String, Duration) - Constructor for class kafka.tier.store.GcsTierObjectStoreConfig
-
- gcsWriteChunkSize - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
-
- generalOperationStatus() - Method in class kafka.common.BrokerAdditionDescriptionInternal
-
- generalOperationStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- generateBackendConfig(TierObjectStore.Backend, Properties) - Static method in class kafka.tier.store.TierObjectStoreUtils
-
This method generates the TierStoreConfig for the various backends.
- generateKeyPrefix(String) - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- generateNextObjectsListName(String) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Convenience method to create the name for the next backup objects list, given the current list's name.
- generation() - Method in class kafka.internals.generated.GroupMetadataValue
-
- get(TopicPartition, String, long) - Method in class kafka.restore.RestorePartitionOperatorFactory
-
- get() - Method in class kafka.tier.client.TierTopicConsumerSupplier
-
- get() - Method in class kafka.tier.client.TierTopicProducerSupplier
-
- get(UUID, long) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
-
- getAnyRetentionPeriodReductions(Long, LifecycleManagerState, Map<String, Integer>) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
This method determines reduction to the backup objects' retention for a topic.
- getBackend() - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- getBackend() - Method in class kafka.tier.store.GcsTierObjectStore
-
- getBackend() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- getBackend() - Method in class kafka.tier.store.S3TierObjectStore
-
- getBackend() - Method in interface kafka.tier.store.TierObjectStore
-
- getBackend() - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- getBackupObjectListNames(TierObjectStore, String) - Static method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils
-
Gets the names of all the backup object lists from the object store
- getBackupRetentionInDaysForAllTopics(Map<String, Long>) - Static method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
Determines the backup object retention in days for a topic, given the topic's retention.ms configuration value
- getBrokerID() - Method in class kafka.restore.messages.KafkaRequest
-
- getBrokerUrl(int) - Static method in class kafka.restore.schedulers.SchedulerUtil
-
Constructs the URL for the given broker ID.
- getCause() - Method in exception kafka.restore.statemachine.api.FiniteStateMachineException
-
- getChoice() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- getConsumerPositions() - Method in class kafka.tier.backupObjectLifecycle.TierTopicReader
-
Returns the consumer positions.
- getContentHash() - Method in class kafka.restore.messages.KafkaForceRestoreRequest
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.CopyObjectInStoreResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaFenceResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaFetchFtpsResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaForceRestoreResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaTierPartitionStatusResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaUnfreezeResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.KafkaValidateLogRangeResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.ListObjectsInStoreResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.MessageResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.ReconcileFtpsResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.RestoreFtpsResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.RestoreObjectsInStoreResponse
-
- getCorrespondingRequestTypeName() - Method in class kafka.restore.messages.UploadFtpsToStoreResponse
-
- getCreateTimestamp() - Method in class kafka.restore.messages.Message
-
- getCreationTime() - Method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils.DeletionRecord
-
- getData(String) - Method in interface kafka.restore.statemachine.api.Event
-
Get data stored along with the Event
- getData(String) - Method in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- getDateFromKey(String) - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- getDeletedSegments() - Method in class kafka.tier.backupObjectLifecycle.TierTopicReader
-
Consume the tier state topic and get information about segments that have been deleted by Kafka, since the last run
of this consumer.
- getDeletionList(StateManagerConfig, String, String) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Gets the deletion list for a given date and namePrefix.
- getEvent() - Method in exception kafka.restore.statemachine.api.FiniteStateMachineException
-
- getException() - Method in class kafka.common.BrokerAddStatus
-
- getExpectedStatus() - Method in class kafka.restore.messages.KafkaTierPartitionStatusRequest
-
- getFailedSegmentIds() - Method in class kafka.restore.messages.RestoreObjectsInStoreResponse
-
- getFiniteStateMachineByTopicPartition(TopicPartition) - Method in class kafka.restore.statemachine.StateMachineController
-
- getFromTimestamp() - Method in class kafka.restore.configmap.TopicConfig
-
- getFromTimestamp() - Method in class kafka.restore.messages.ReconcileFtpsRequest
-
- getFromTimestamp() - Method in class kafka.restore.messages.RestoreFtpsRequest
-
- getFtpsFileName() - Method in class kafka.restore.messages.KafkaFetchFtpsResponse
-
- getFtpsFilePath() - Method in class kafka.restore.messages.AsyncTaskRequest
-
- getFtpsFilePath() - Method in class kafka.restore.messages.UploadFtpsToStoreRequest
-
- getFtpsHeader(File) - Static method in class kafka.restore.operators.OperatorUtil
-
Get the header of given Ftps file
- getHeader() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- getHost() - Method in class kafka.restore.configmap.NodeConfig
-
- getId() - Method in class kafka.restore.configmap.NodeConfig
-
- getInput() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- getInputStream() - Method in interface kafka.tier.store.TierObjectStoreResponse
-
- getInstance() - Static method in class kafka.restore.RestoreConfig
-
- getJobs() - Method in class kafka.restore.db.FileRestoreDB
-
- getJobs() - Method in interface kafka.restore.db.RestoreDB
-
get the Job list
- getKafkaTopicRetentionMs() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
Gets retention ms config for all the non-internal topics in the Kafka cluster
- getLastLiveVersionId(String, List<VersionInformation>) - Static method in class kafka.restore.schedulers.SchedulerUtil
-
The assumption is Kafka TierStorage only add/delete objects in/from object store, it never "overwrite"
an object.
- getLastUpdateTime() - Method in class kafka.common.BrokerAddStatus
-
- getLeader() - Method in class kafka.restore.configmap.PartitionConfig
-
- getLifecycleManagerState(Long) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
Gets the lifecycle Manager state.
- getListNameFromKey(String) - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- getLogEndOffset() - Method in class kafka.restore.messages.KafkaForceRestoreRequest
-
- getLogEndOffset() - Method in class kafka.restore.messages.KafkaValidateLogRangeRequest
-
- getLogStartOffset() - Method in class kafka.restore.messages.KafkaForceRestoreRequest
-
- getLogStartOffset() - Method in class kafka.restore.messages.KafkaValidateLogRangeRequest
-
- getMetadata(String) - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
Matadata to store additional information
- getMetadata(String) - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- getName() - Method in class kafka.restore.configmap.TopicConfig
-
- getName() - Method in interface kafka.restore.statemachine.api.Event
-
- getName() - Method in class kafka.restore.statemachine.api.State
-
- getName() - Method in interface kafka.restore.statemachine.api.Transition
-
Return transition name.
- getName() - Method in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- getName() - Method in class kafka.restore.statemachine.transitions.AbstractTransition
-
- getName() - Method in enum kafka.tier.store.TierObjectStore.Backend
-
- getNumPartitions(Producer<byte[], byte[]>, String) - Static method in class kafka.tier.tools.RecoveryUtils
-
Discovers and returns the number of partitions in the provided topicName.
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.GcsTierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.S3TierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in interface kafka.tier.store.TierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer) - Method in interface kafka.tier.store.TierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
-
- getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- getObjectCounts() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- getObjectId() - Method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils.DeletionRecord
-
- getObjectMap() - Method in class kafka.restore.messages.ListObjectsInStoreResponse
-
- getObjectPath() - Method in class kafka.restore.messages.CopyObjectInStoreRequest
-
- getObjectPath() - Method in class kafka.restore.messages.CopyObjectInStoreResponse
-
- getObjectStoreInstance(Time, TierObjectStore.Backend, TierObjectStoreConfig) - Static method in class kafka.tier.tools.TierObjectStoreFactory
-
This method will instantiate the necessary backend store instance and then return the same instance for
consecutive requests.
- getOperatorContext() - Method in class kafka.restore.operators.ReconcilePartitionOperator
-
- getOptimalPoolSizeForKafka(double) - Static method in class kafka.restore.schedulers.SchedulerUtil
-
Returns the optimal pool size based on available number of cores.
- getPartition() - Method in class kafka.restore.configmap.PartitionConfig
-
- getPartition() - Method in class kafka.restore.messages.Message
-
- getPartitionConfigs() - Method in class kafka.restore.configmap.TopicConfig
-
- getPartitionContextCount() - Method in class kafka.restore.db.FileRestoreDB
-
- getPartitionContextCount() - Method in interface kafka.restore.db.RestoreDB
-
The total number of partition contexts in db
- getPartitionCount() - Method in class kafka.restore.db.Job
-
- getPath() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- getPort() - Method in class kafka.restore.configmap.NodeConfig
-
- getProperties() - Method in class kafka.restore.RestoreConfig
-
- getProperty(String) - Static method in class kafka.restore.RestoreConfig
-
- getRematerialized() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- getReplica() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- getReplicaBrokerIDs() - Method in class kafka.restore.messages.KafkaTierPartitionStatusRequest
-
- getReplicaBrokerIDs() - Method in class kafka.restore.messages.KafkaValidateLogRangeRequest
-
- getReplicas() - Method in class kafka.restore.configmap.PartitionConfig
-
- getReplicas() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- getRequestID() - Method in class kafka.restore.messages.MessageResponse
-
- getResult() - Method in class kafka.restore.messages.MessageResponse
-
- getResultsReceiver() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
- getRootAsBackupObjectsMetadata(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- getRootAsBackupObjectsMetadata(ByteBuffer, BackupObjectsMetadata) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- getRootAsBlobMetadata(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- getRootAsBlobMetadata(ByteBuffer, BlobMetadata) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- getRootAsCheckedFileIOHeader(ByteBuffer) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- getRootAsCheckedFileIOHeader(ByteBuffer, CheckedFileIOHeader) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- getRootAsCompactionCommitAndSwap(ByteBuffer) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- getRootAsCompactionCommitAndSwap(ByteBuffer, CompactionCommitAndSwap) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- getRootAsDatabase(ByteBuffer) - Static method in class kafka.durability.db.serdes.Database
-
- getRootAsDatabase(ByteBuffer, Database) - Static method in class kafka.durability.db.serdes.Database
-
- getRootAsDatabase(ByteBuffer) - Static method in class kafka.durability.restore.db.serdes.Database
-
- getRootAsDatabase(ByteBuffer, Database) - Static method in class kafka.durability.restore.db.serdes.Database
-
- getRootAsDatedList(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- getRootAsDatedList(ByteBuffer, DatedList) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- getRootAsDeletePartition(ByteBuffer) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- getRootAsDeletePartition(ByteBuffer, DeletePartition) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- getRootAsDeleteRecords(ByteBuffer) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- getRootAsDeleteRecords(ByteBuffer, DeleteRecords) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- getRootAsEpochChange(ByteBuffer) - Static method in class kafka.durability.events.serdes.EpochChange
-
- getRootAsEpochChange(ByteBuffer, EpochChange) - Static method in class kafka.durability.events.serdes.EpochChange
-
- getRootAsEventKey(ByteBuffer) - Static method in class kafka.durability.events.serdes.EventKey
-
- getRootAsEventKey(ByteBuffer, EventKey) - Static method in class kafka.durability.events.serdes.EventKey
-
- getRootAsHeader(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- getRootAsHeader(ByteBuffer, Header) - Static method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- getRootAsHeader(ByteBuffer) - Static method in class kafka.durability.db.serdes.Header
-
- getRootAsHeader(ByteBuffer, Header) - Static method in class kafka.durability.db.serdes.Header
-
- getRootAsHeader(ByteBuffer) - Static method in class kafka.durability.restore.db.serdes.Header
-
- getRootAsHeader(ByteBuffer, Header) - Static method in class kafka.durability.restore.db.serdes.Header
-
- getRootAsHealthCheck(ByteBuffer) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- getRootAsHealthCheck(ByteBuffer, HealthCheck) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- getRootAsInitLeader(ByteBuffer) - Static method in class kafka.tier.serdes.InitLeader
-
- getRootAsInitLeader(ByteBuffer, InitLeader) - Static method in class kafka.tier.serdes.InitLeader
-
- getRootAsIsrExpand(ByteBuffer) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- getRootAsIsrExpand(ByteBuffer, IsrExpand) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- getRootAsJob(ByteBuffer) - Static method in class kafka.durability.restore.db.serdes.Job
-
- getRootAsJob(ByteBuffer, Job) - Static method in class kafka.durability.restore.db.serdes.Job
-
- getRootAsLifecycleManagerState(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- getRootAsLifecycleManagerState(ByteBuffer, LifecycleManagerState) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- getRootAsMaterializationTrackingInfo(ByteBuffer) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- getRootAsMaterializationTrackingInfo(ByteBuffer, MaterializationTrackingInfo) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- getRootAsOffsetChange(ByteBuffer) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- getRootAsOffsetChange(ByteBuffer, OffsetChange) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- getRootAsPartitionDeleteComplete(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- getRootAsPartitionDeleteComplete(ByteBuffer, PartitionDeleteComplete) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- getRootAsPartitionDeleteInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- getRootAsPartitionDeleteInitiate(ByteBuffer, PartitionDeleteInitiate) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- getRootAsPartitionDeletePreInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- getRootAsPartitionDeletePreInitiate(ByteBuffer, PartitionDeletePreInitiate) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- getRootAsPartitionFence(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionFence
-
- getRootAsPartitionFence(ByteBuffer, PartitionFence) - Static method in class kafka.tier.serdes.PartitionFence
-
- getRootAsPartitionForceRestore(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- getRootAsPartitionForceRestore(ByteBuffer, PartitionForceRestore) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- getRootAsPartitionInfo(ByteBuffer) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- getRootAsPartitionInfo(ByteBuffer, PartitionInfo) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- getRootAsPartitionRestoreContext(ByteBuffer) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- getRootAsPartitionRestoreContext(ByteBuffer, PartitionRestoreContext) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- getRootAsPartitionUnfreezeLogStartOffset(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- getRootAsPartitionUnfreezeLogStartOffset(ByteBuffer, PartitionUnfreezeLogStartOffset) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- getRootAsRetentionChange(ByteBuffer) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- getRootAsRetentionChange(ByteBuffer, RetentionChange) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- getRootAsSegmentDeleteComplete(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- getRootAsSegmentDeleteComplete(ByteBuffer, SegmentDeleteComplete) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- getRootAsSegmentDeleteInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- getRootAsSegmentDeleteInitiate(ByteBuffer, SegmentDeleteInitiate) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- getRootAsSegmentUploadComplete(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- getRootAsSegmentUploadComplete(ByteBuffer, SegmentUploadComplete) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- getRootAsSegmentUploadInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- getRootAsSegmentUploadInitiate(ByteBuffer, SegmentUploadInitiate) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- getRootAsStartOffsetChange(ByteBuffer) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- getRootAsStartOffsetChange(ByteBuffer, StartOffsetChange) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- getRootAsTierKafkaKey(ByteBuffer) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- getRootAsTierKafkaKey(ByteBuffer, TierKafkaKey) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- getRootAsTierPartitionStateEntry(ByteBuffer) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- getRootAsTierPartitionStateEntry(ByteBuffer, TierPartitionStateEntry) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- getRootAsTierPartitionStateHeader(ByteBuffer) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- getRootAsTierPartitionStateHeader(ByteBuffer, TierPartitionStateHeader) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- getRootAsTopicInfo(ByteBuffer) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- getRootAsTopicInfo(ByteBuffer, TopicInfo) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- getRootAsTopicMetadata(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- getRootAsTopicMetadata(ByteBuffer, TopicMetadata) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- getRootAsTopicRetentionData(ByteBuffer) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- getRootAsTopicRetentionData(ByteBuffer, TopicRetentionData) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- getSegmentAndPathMap() - Method in class kafka.restore.messages.RestoreFtpsResponse
-
- getSegmentDirectoryPath() - Method in class kafka.restore.messages.ListObjectsInStoreRequest
-
- getSegmentId() - Method in class kafka.restore.messages.CopyObjectInStoreRequest
-
- getSegmentId() - Method in class kafka.restore.messages.CopyObjectInStoreResponse
-
- getSegmentId() - Method in class kafka.restore.messages.ListObjectsInStoreRequest
-
- getSegmentId() - Method in class kafka.restore.messages.ListObjectsInStoreResponse
-
- getSegmentPathMap() - Method in class kafka.restore.messages.RestoreObjectsInStoreRequest
-
- getSegmentsMap() - Method in class kafka.restore.messages.ReconcileFtpsRequest
-
- getSourceState() - Method in interface kafka.restore.statemachine.api.Transition
-
Return transition source state.
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FenceEventSentToPartitionFencedTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.ForceRestoreEventSentToPartitionRestoredTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsFetchedToFtpsRepairedTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsFetchedToPartitionRestoredTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsReconciledToFtpsUploadedTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsRepairedToFtpsReconciledTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsRepairedToSegmentsRepairedTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.FtpsUploadedToForceRestoreEventSentTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.PartitionFencedToFtpsFetchedTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.PartitionRestoredToRestoreStartOffsetEventSentTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.RestoreStartOffsetEventSentToStartOffsetRestoredTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.SegmentsRepairedToFtpsReconciledTransition
-
- getSourceState() - Method in class kafka.restore.statemachine.transitions.StartToFenceEventSentTransition
-
- getSourceVersionId() - Method in class kafka.restore.messages.CopyObjectInStoreRequest
-
- getStartOffset(TopicPartition) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
-
getStartOffset will return the beginning offset of a given TopicPartition 'tp'.
- getStartTime() - Method in class kafka.common.BrokerAddStatus
-
- getState(StateManagerConfig) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Gets the Lifecycle Manager state from object store.
- getStatus() - Method in class kafka.restore.RestoreOrchestrator
-
- getStatus() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
- getStatusCode() - Method in class kafka.restore.messages.MessageResponse
-
- getStored() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- getStoredKeys() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
Returns the set of keys which are currently stored.
- getTargetState() - Method in interface kafka.restore.statemachine.api.Transition
-
Return transition target state.
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FenceEventSentToPartitionFencedTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.ForceRestoreEventSentToPartitionRestoredTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsFetchedToFtpsRepairedTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsFetchedToPartitionRestoredTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsReconciledToFtpsUploadedTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsRepairedToFtpsReconciledTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsRepairedToSegmentsRepairedTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.FtpsUploadedToForceRestoreEventSentTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.PartitionFencedToFtpsFetchedTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.PartitionRestoredToRestoreStartOffsetEventSentTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.RestoreStartOffsetEventSentToStartOffsetRestoredTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.SegmentsRepairedToFtpsReconciledTransition
-
- getTargetState() - Method in class kafka.restore.statemachine.transitions.StartToFenceEventSentTransition
-
- getThreadPoolExecutorStatus(String, ThreadPoolExecutor) - Static method in class kafka.restore.schedulers.SchedulerUtil
-
- getTierPartitionStatus() - Method in class kafka.restore.messages.KafkaTierPartitionStatusResponse
-
- getTierStateFile(TopicIdPartition) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
-
- getTimestamp() - Method in interface kafka.restore.statemachine.api.Event
-
- getTimestamp() - Method in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- getTopic() - Method in class kafka.restore.messages.Message
-
- getTopicConfigs() - Method in class kafka.restore.configmap.RestoreTopicListConfig
-
- getTopicIdPartition() - Method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils.DeletionRecord
-
- getTopicName() - Method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils.DeletionRecord
-
- getTransition() - Method in exception kafka.restore.statemachine.api.FiniteStateMachineException
-
- getTypeId(byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
-
Deserializes just the type from a value read from a Tier State Topic
- getUuid() - Method in class kafka.restore.messages.Message
-
- getValue() - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
Returns the Adler32 checksum value
- getVersionId() - Method in class kafka.tier.store.MockInMemoryTierObjectStore.UploadedObject
-
- getVersionId() - Method in class kafka.tier.store.VersionInformation
-
- globalMaterializedEpoch() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- globalMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- globalMaterializedOffsetAndEpoch() - Method in class kafka.tier.state.Header
-
- group() - Method in class kafka.internals.generated.GroupMetadataKey
-
- group() - Method in class kafka.internals.generated.OffsetCommitKey
-
- groupInstanceId() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- GroupMetadataKey - Class in kafka.internals.generated
-
- GroupMetadataKey(Readable, short) - Constructor for class kafka.internals.generated.GroupMetadataKey
-
- GroupMetadataKey(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.GroupMetadataKey
-
- GroupMetadataKey() - Constructor for class kafka.internals.generated.GroupMetadataKey
-
- GroupMetadataValue - Class in kafka.internals.generated
-
- GroupMetadataValue(Readable, short) - Constructor for class kafka.internals.generated.GroupMetadataValue
-
- GroupMetadataValue(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.GroupMetadataValue
-
- GroupMetadataValue() - Constructor for class kafka.internals.generated.GroupMetadataValue
-
- GroupMetadataValue.MemberMetadata - Class in kafka.internals.generated
-
- id() - Method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- id() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- id() - Method in class kafka.common.TopicPlacement.Replica
-
- id() - Method in class kafka.durability.restore.db.serdes.Job
-
- id - Variable in class kafka.restore.db.Job
-
- id() - Method in enum kafka.tier.domain.TierObjectMetadata.State
-
- idAsByteBuffer() - Method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- idAsByteBuffer() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- idInByteBuffer(ByteBuffer) - Method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- idInByteBuffer(ByteBuffer) - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- IncompatibleKeysetException - Exception in kafka.tier.store.encryption
-
- IncompatibleKeysetException(String) - Constructor for exception kafka.tier.store.encryption.IncompatibleKeysetException
-
- IncompatibleKeysetException(String, Throwable) - Constructor for exception kafka.tier.store.encryption.IncompatibleKeysetException
-
- indexOf(UUID) - Method in class kafka.restore.operators.FtpsSegmentView
-
Find the index of the given segment in segmentStateList
- info() - Method in class kafka.durability.events.serdes.DeletePartition
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.DeletePartition
-
- info() - Method in class kafka.durability.events.serdes.DeleteRecords
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.DeleteRecords
-
- info() - Method in class kafka.durability.events.serdes.EpochChange
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.EpochChange
-
- info() - Method in class kafka.durability.events.serdes.HealthCheck
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.HealthCheck
-
- info() - Method in class kafka.durability.events.serdes.IsrExpand
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.IsrExpand
-
- info() - Method in class kafka.durability.events.serdes.OffsetChange
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.OffsetChange
-
- info() - Method in class kafka.durability.events.serdes.RetentionChange
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.RetentionChange
-
- info() - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- info(BaseInfo) - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- INITIAL_BACKOFF_MS - Static variable in class kafka.restore.schedulers.Constants
-
Http retry parameters.
- initialBufferSize() - Static method in class kafka.tier.domain.TierObjectMetadata
-
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionDeleteComplete
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionFence
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionForceRestore
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierSegmentDeleteComplete
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierSegmentUploadComplete
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierSegmentUploadInitiate
-
The initial buffer size to use when constructing the FlatBuffer message.
- initialBufferSize() - Static method in class kafka.tier.domain.TierTopicInitLeader
-
The initial buffer size to use when constructing the FlatBuffer message.
- Initialization(Logger, TopicIdPartition, CompletableFuture<Boolean>, int) - Constructor for class kafka.tier.state.FileTierPartitionState.MaterializationListener.Initialization
-
- initialize(InternalAdmin, int, short) - Method in class kafka.tier.topic.TierTopic
-
Initializes the TierTopic by first checking if the tier topic exists.
- initialize(int) - Method in class kafka.tier.topic.TierTopic
-
- initialize(InitializedTierTopic) - Method in class kafka.tier.topic.TierTopicConsumer
-
Start consuming the tier topic.
- InitializedTierTopic - Interface in kafka.tier.topic
-
- initializeMetrics(KafkaConfig, Time, String) - Static method in class kafka.restore.RestoreMetricsUtil
-
- InitLeader - Class in kafka.tier.serdes
-
- InitLeader() - Constructor for class kafka.tier.serdes.InitLeader
-
- initState(File, TopicPartition, LogConfig, LogDirFailureChannel, Scheduler) - Method in class kafka.tier.state.TierPartitionStateFactory
-
- initState(File, TopicPartition, LogConfig, LogDirFailureChannel, Scheduler, Boolean) - Method in class kafka.tier.state.TierPartitionStateFactory
-
- injectFencingEvents(Properties, String, Map<TopicIdPartition, Boolean>) - Static method in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- injectTierTopicEvent(Producer<byte[], byte[]>, AbstractTierMetadata, String, int) - Static method in class kafka.tier.tools.RecoveryUtils
-
Injects an event into the TierTopic, using the provided TierTopic producer object.
- inProgressCount() - Method in class kafka.restore.statemachine.StateMachineController
-
- input() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- input() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- input() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- input() - Method in class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
-
- INPUT_PATH_CONFIG - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- INPUT_PATH_DOC - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- INSTANCE - Static variable in class kafka.metrics.KafkaYammerMetrics
-
- interBrokerClientConfigs - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- interBrokerClientConfigs - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- intern(T) - Method in class kafka.utils.Interner
-
Attempt to swap out the provided T for an interned version which matches based
on Object::hashcode.
- Interner<T> - Class in kafka.utils
-
A thread-safe object interner which uses weak references for cleanup.
- Interner() - Constructor for class kafka.utils.Interner
-
- intoByteArray() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- intoLongArray() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- isAllTasksDone() - Method in class kafka.restore.statemachine.StateMachineController
-
- isCancelled() - Method in class kafka.tier.fetcher.CancellationContext
-
Get the cancellation status of this CancellationContext.
- isComplete() - Method in class kafka.tier.fetcher.PendingFetch
-
Checks if the pending fetch has finished
- isComplete() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
- isConfigValid(Logger, String, LogConfig) - Static method in class kafka.tier.topic.TierTopic
-
- isDeleteMarker() - Method in class kafka.tier.store.S3VersionInformation
-
- isDisabled() - Method in class kafka.tier.fetcher.MemoryTracker
-
Returns true if this MemoryTracker is disabled.
- isDone() - Method in class kafka.restore.db.Job
-
- isDone() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
- isEmpty() - Method in class kafka.tier.fetcher.TierFetchResult
-
- isEmpty() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- isErrorStatusReachedViaFenceEvent() - Method in class kafka.tier.state.FileTierPartitionState
-
- isLifecycleManagerActive() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- isNewTopic() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
- isObjectDeleted() - Method in class kafka.tier.store.S3VersionInformation
-
- isOpen() - Method in enum kafka.tier.state.TierPartitionStatus
-
- isOpenForWrite() - Method in enum kafka.tier.state.TierPartitionStatus
-
- isPartitionRegistered(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicConsumer
-
Check if topic partition is registered.
- isPendingDeletion() - Method in enum kafka.tier.state.TierPartitionStatus
-
- isr(int) - Method in class kafka.durability.events.serdes.DeleteRecords
-
- isr(int) - Method in class kafka.durability.events.serdes.EpochChange
-
- isr(int) - Method in class kafka.durability.events.serdes.OffsetChange
-
- isr(int) - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- isrAsByteBuffer() - Method in class kafka.durability.events.serdes.DeleteRecords
-
- isrAsByteBuffer() - Method in class kafka.durability.events.serdes.EpochChange
-
- isrAsByteBuffer() - Method in class kafka.durability.events.serdes.OffsetChange
-
- isrAsByteBuffer() - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- isReady() - Method in interface kafka.tier.topic.TierTopicAppender
-
Return whether TierTopicManager is ready to accept writes.
- isReady() - Method in class kafka.tier.topic.TierTopicConsumer
-
- isReady() - Method in class kafka.tier.topic.TierTopicManager
-
Return whether TierTopicManager is ready to accept writes.
- isRestoreDBEmpty(RestoreDB) - Static method in class kafka.restore.db.Utils
-
- IsrExpand - Class in kafka.durability.events.serdes
-
- IsrExpand() - Constructor for class kafka.durability.events.serdes.IsrExpand
-
- isrInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.DeleteRecords
-
- isrInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.EpochChange
-
- isrInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.OffsetChange
-
- isrInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- isrLength() - Method in class kafka.durability.events.serdes.DeleteRecords
-
- isrLength() - Method in class kafka.durability.events.serdes.EpochChange
-
- isrLength() - Method in class kafka.durability.events.serdes.OffsetChange
-
- isrLength() - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- isTenantPrefixed(String) - Static method in class kafka.common.TenantHelpers
-
- isTenantPrefixed(TopicPartition) - Static method in class kafka.common.TenantHelpers
-
- isTieringEnabled() - Method in class kafka.tier.state.FileTierPartitionState
-
- isTieringEnabled() - Method in interface kafka.tier.state.TierPartitionState
-
- isTierTopicClient(String) - Static method in class kafka.tier.client.TierTopicClient
-
Check if the clientId is one used by tier topic clients.
- isValidationSuccess() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- isValidPath(Algorithm, Path) - Static method in class kafka.utils.checksum.CheckedFileIO
-
isValidPath is a helper util to check if the input file is in algorithm specific format
if algo = ChecksumAlgorithm.ADLER
somePath/tierMetadata.adler -> true
somePath/tierMetadata -> false
if algo = ChecksumAlgorithm.NO_CHECKSUM
somePath/tierMetadata -> true
somePath/tierMetadata.adler -> false
- isValidStates(Iterator<TierObjectMetadata>, Iterator<TierObjectMetadata>, long, Optional<TierObjectStore>, boolean, CancellationContext, Function<TopicPartition, Long>) - Static method in class kafka.tier.tools.TierMetadataValidator
-
- iterator(TopicPartition, CheckedFileIO) - Static method in class kafka.tier.state.FileTierPartitionState
-
- kafka.assignor - package kafka.assignor
-
- kafka.backupRestore.objectLifecycle.serdes - package kafka.backupRestore.objectLifecycle.serdes
-
- kafka.common - package kafka.common
-
- kafka.controller - package kafka.controller
-
- kafka.durability.db.serdes - package kafka.durability.db.serdes
-
- kafka.durability.events.serdes - package kafka.durability.events.serdes
-
- kafka.durability.restore.db.serdes - package kafka.durability.restore.db.serdes
-
- kafka.durability.tools - package kafka.durability.tools
-
- kafka.internals.generated - package kafka.internals.generated
-
- kafka.metrics - package kafka.metrics
-
- kafka.restore - package kafka.restore
-
- kafka.restore.configmap - package kafka.restore.configmap
-
- kafka.restore.db - package kafka.restore.db
-
- kafka.restore.messages - package kafka.restore.messages
-
- kafka.restore.operators - package kafka.restore.operators
-
- kafka.restore.rest - package kafka.restore.rest
-
- kafka.restore.schedulers - package kafka.restore.schedulers
-
- kafka.restore.statemachine - package kafka.restore.statemachine
-
- kafka.restore.statemachine.api - package kafka.restore.statemachine.api
-
- kafka.restore.statemachine.events - package kafka.restore.statemachine.events
-
- kafka.restore.statemachine.transitions - package kafka.restore.statemachine.transitions
-
- kafka.server.builders - package kafka.server.builders
-
- kafka.tier - package kafka.tier
-
- kafka.tier.backupObjectLifecycle - package kafka.tier.backupObjectLifecycle
-
- kafka.tier.client - package kafka.tier.client
-
- kafka.tier.domain - package kafka.tier.domain
-
- kafka.tier.exceptions - package kafka.tier.exceptions
-
- kafka.tier.fetcher - package kafka.tier.fetcher
-
- kafka.tier.fetcher.offsetcache - package kafka.tier.fetcher.offsetcache
-
- kafka.tier.serdes - package kafka.tier.serdes
-
- kafka.tier.state - package kafka.tier.state
-
- kafka.tier.store - package kafka.tier.store
-
- kafka.tier.store.encryption - package kafka.tier.store.encryption
-
- kafka.tier.tools - package kafka.tier.tools
-
- kafka.tier.tools.common - package kafka.tier.tools.common
-
- kafka.tier.topic - package kafka.tier.topic
-
- kafka.tools - package kafka.tools
-
- kafka.utils - package kafka.utils
-
- kafka.utils.checksum - package kafka.utils.checksum
-
- KAFKA_CLUSTER_ID - Static variable in class kafka.restore.RestoreMetricsUtil
-
- KAFKA_INTERNAL_REST_SERVER_PORT - Static variable in class kafka.restore.RestoreConfig
-
- KAFKA_MAX_RETRIES - Static variable in class kafka.restore.schedulers.Constants
-
- KAFKA_NODE_ID - Static variable in class kafka.restore.RestoreMetricsUtil
-
- KafkaApisBuilder - Class in kafka.server.builders
-
- KafkaApisBuilder() - Constructor for class kafka.server.builders.KafkaApisBuilder
-
- kafkaConfig() - Static method in class kafka.restore.RestoreConfig
-
- KafkaConnectionPool - Interface in kafka.restore.schedulers
-
Interface for KafkaConnectionPools
- KafkaConnectionPoolImpl - Class in kafka.restore.schedulers
-
Connection pool for scheduling async restore-related requests to Kafka brokers
- KafkaConnectionPoolImpl(AsyncServiceSchedulerResultsReceiver, int, String) - Constructor for class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Constructs new KafkaConnectionPool with given resultsReceiver.
- KafkaFenceRequest - Class in kafka.restore.messages
-
- KafkaFenceRequest(int, String, int, int) - Constructor for class kafka.restore.messages.KafkaFenceRequest
-
- KafkaFenceResponse - Class in kafka.restore.messages
-
- KafkaFenceResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaFenceResponse
-
- KafkaFetchFtpsRequest - Class in kafka.restore.messages
-
Request of type KAFKA_FETCH_FTPS to fetch FTPS file from a broker.
- KafkaFetchFtpsRequest(int, String, int, int) - Constructor for class kafka.restore.messages.KafkaFetchFtpsRequest
-
Constructs new FetchFtpsRequest.
- KafkaFetchFtpsResponse - Class in kafka.restore.messages
-
- KafkaFetchFtpsResponse(int, String, int, int, MessageStatusCode, MessageResult, String) - Constructor for class kafka.restore.messages.KafkaFetchFtpsResponse
-
Constructs new FetchFtpsResponse for successful request.
- KafkaFetchFtpsResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaFetchFtpsResponse
-
Constructs new FetchFtpsResponse for failed request.
- KafkaForceRestoreRequest - Class in kafka.restore.messages
-
- KafkaForceRestoreRequest(int, String, int, int, long, long, String) - Constructor for class kafka.restore.messages.KafkaForceRestoreRequest
-
- KafkaForceRestoreResponse - Class in kafka.restore.messages
-
- KafkaForceRestoreResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaForceRestoreResponse
-
- KafkaManager - Class in kafka.restore.schedulers
-
KafkaManager for scheduling and processing asynchronous calls to Kafka REST API for restore task.
- KafkaManager(AsyncServiceSchedulerResultsReceiver, KafkaConnectionPool, int) - Constructor for class kafka.restore.schedulers.KafkaManager
-
Constructs new KafkaManager.
- KafkaManager(AsyncServiceSchedulerResultsReceiver, KafkaConnectionPool) - Constructor for class kafka.restore.schedulers.KafkaManager
-
Constructs new KafkaManager with default request queue capacity.
- KafkaRequest - Class in kafka.restore.messages
-
Abstract KafkaRequest class for all requests made to KafkaManager
- KafkaRequest(int, String, int, int) - Constructor for class kafka.restore.messages.KafkaRequest
-
Constructs a new KafkaRequest.
- KafkaResponse - Class in kafka.restore.messages
-
Abstract KafkaResponse class for responses to all
KafkaRequest
s.
- KafkaResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaResponse
-
Constructs new KafkaResponse.
- KafkaRestoreEvent - Class in kafka.restore.statemachine.events
-
- KafkaRestoreEvent(MessageResponse) - Constructor for class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- KafkaTierPartitionStatusRequest - Class in kafka.restore.messages
-
Request of type KAFKA_TIER_PARTITION_STATUS to get the current status of a certain tier partition.
- KafkaTierPartitionStatusRequest(int, String, int, int, List<Integer>, int) - Constructor for class kafka.restore.messages.KafkaTierPartitionStatusRequest
-
Creates new KafkaTierPartitionStatusRequest.
- KafkaTierPartitionStatusResponse - Class in kafka.restore.messages
-
- KafkaTierPartitionStatusResponse(int, String, int, int, MessageStatusCode, MessageResult, String) - Constructor for class kafka.restore.messages.KafkaTierPartitionStatusResponse
-
Creates new KafkaTierPartitionStatusRequest with non-null tierPartitionStatus.
- KafkaTierPartitionStatusResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaTierPartitionStatusResponse
-
Creates new KafkaTierPartitionStatusRequest with null tierPartitionStatus (because status could not be
determined).
- kafkaTopicId() - Method in class kafka.tier.TopicIdPartition
-
- KafkaUnfreezeRequest - Class in kafka.restore.messages
-
- KafkaUnfreezeRequest(int, String, int, int) - Constructor for class kafka.restore.messages.KafkaUnfreezeRequest
-
- KafkaUnfreezeResponse - Class in kafka.restore.messages
-
- KafkaUnfreezeResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaUnfreezeResponse
-
- KafkaValidateLogRangeRequest - Class in kafka.restore.messages
-
- KafkaValidateLogRangeRequest(int, String, int, int, List<Integer>, long, long) - Constructor for class kafka.restore.messages.KafkaValidateLogRangeRequest
-
- KafkaValidateLogRangeResponse - Class in kafka.restore.messages
-
- KafkaValidateLogRangeResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.KafkaValidateLogRangeResponse
-
- KafkaYammerMetrics - Class in kafka.metrics
-
This class encapsulates the default yammer metrics registry for Kafka server,
and configures the set of exported JMX metrics for Yammer metrics.
- key() - Method in class kafka.tier.store.TierObjectStore.KeyAndVersion
-
- KeyAndVersion(String) - Constructor for class kafka.tier.store.TierObjectStore.KeyAndVersion
-
- KeyAndVersion(String, String) - Constructor for class kafka.tier.store.TierObjectStore.KeyAndVersion
-
- keyBaseOffset() - Method in class kafka.tier.state.SegmentState
-
- keyContext(KeySha) - Method in class kafka.tier.store.encryption.EncryptionKeyManager
-
Returns the context necessary to upload or download an encrypted object.
- KeyContext - Class in kafka.tier.store.encryption
-
Context required to upload an encrypted object to tiered storage.
- KeyContext(CleartextDataKey, HashMap<String, String>, KeySha) - Constructor for class kafka.tier.store.encryption.KeyContext
-
- keySha - Variable in class kafka.tier.store.encryption.KeyContext
-
- KeySha - Class in kafka.tier.store.encryption
-
- main(String[]) - Static method in class kafka.durability.tools.DumpDurabilityDb
-
- main(String[]) - Static method in class kafka.restore.configmap.TopicPartitionConfigMapGenerator
-
- main(String[]) - Static method in class kafka.restore.Restore
-
- main(String[]) - Static method in class kafka.restore.RestoreTierPartitionState
-
- main(String[]) - Static method in class kafka.tier.tools.DumpTierPartitionState
-
- main(String[]) - Static method in class kafka.tier.tools.TierMetadataComparator
-
- main(String[]) - Static method in class kafka.tier.tools.TierMetadataDebugger
-
- main(String[]) - Static method in class kafka.tier.tools.TierMetadataValidator
-
- main(String[]) - Static method in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- main(String[]) - Static method in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- main(String[]) - Static method in class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
-
- main(String[]) - Static method in class kafka.tools.StreamsResetter
-
- makeArgument(String) - Static method in class kafka.tier.tools.RecoveryUtils
-
- makeNext() - Method in class kafka.restore.operators.SegmentStateIterator
-
- makeNext() - Method in class kafka.tier.state.FileTierPartitionIterator
-
- markFetchExpired() - Method in class kafka.tier.fetcher.PendingFetch
-
- matches(Map<String, String>) - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- matchesInternalTopicFormat(String) - Static method in class kafka.tools.StreamsResetter
-
- matchesObservers(Map<String, String>) - Method in class kafka.common.TopicPlacement
-
Determines if a set of attributes matches the observers constraints.
- matchesReplicas(Map<String, String>) - Method in class kafka.common.TopicPlacement
-
Determines if a set of attributes matches the replicas constraints.
- materializationInfo() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- materializationInfo(MaterializationTrackingInfo) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- materializationLag() - Method in class kafka.tier.state.FileTierPartitionState
-
- materializationLag() - Method in interface kafka.tier.state.TierPartitionState
-
Return the current tier materialization lag.
- materializationLag() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
Retrieve lag of tiered partition.
- materializationPath - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- materializationProgress(long) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- materializationProgress(long) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- MaterializationTrackingInfo - Class in kafka.tier.serdes
-
- MaterializationTrackingInfo() - Constructor for class kafka.tier.serdes.MaterializationTrackingInfo
-
- MATERIALIZE - Static variable in class kafka.tier.tools.TierRecoveryConfig
-
- MATERIALIZE - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- materialize - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- MATERIALIZE_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- materializeUptoLeaderEpoch(int) - Method in class kafka.tier.state.FileTierPartitionState
-
Listen for the flushed materialization state to reach or surpass the provided LeaderEpoch.
- materializeUptoLeaderEpoch(int) - Method in interface kafka.tier.state.TierPartitionState
-
Sets up a listener for this tier partition state.
- materializeUptoObjectIdAndRestoreEpoch(long, UUID, int) - Method in class kafka.tier.state.FileTierPartitionState
-
Listen for the flushed materialization state to materialize a fully uploaded segment matching the provided targetObjectId.
- materializeUptoObjectIdAndRestoreEpoch(long, UUID, int) - Method in interface kafka.tier.state.TierPartitionState
-
Sets up a listener for this tier partition stae for use by the replica fetcher.
- materializeUptoOffset(long) - Method in class kafka.tier.state.FileTierPartitionState
-
Listen for the flushed materialization state to reach or surpass the provided targetOffset.
- materializeUptoOffset(long) - Method in interface kafka.tier.state.TierPartitionState
-
Sets up a listener for this tier partition state for use by the replica fetcher.
- MAX_SEGMENTS_PER_BATCH - Static variable in class kafka.restore.schedulers.ObjectStoreManager
-
Maximum number of segments to send in one batch.
- maxTimestamp() - Method in class kafka.tier.domain.TierObjectMetadata
-
- maxTimestamp() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- maxTimestamp() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- maxTimestamp() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- maxTimestamp() - Method in class kafka.tier.state.SegmentState
-
- maybeBuildAssignor(Optional<KafkaPrincipal>) - Method in interface kafka.assignor.TopicReplicaAssignorBuilder
-
- maybeCloseConsumer() - Method in class kafka.tier.backupObjectLifecycle.TierTopicReader
-
To be used by the caller to close the consumer
- maybeMigrateChecksumFormat(Algorithm, short, Path) - Static method in class kafka.tier.state.ChecksumMigration
-
maybeMigrateChecksumFormat is a helper util to migrate a given file path into the checksumAlgorithm file format.
- maybeOpenChannelOnOffsetTieredException() - Method in class kafka.tier.state.FileTierPartitionState
-
- maybeOpenChannelOnOffsetTieredException() - Method in interface kafka.tier.state.TierPartitionState
-
Called when a replica receives OFFSET_TIERED exception while replicating from leader.
- maybeRemovePreviousFormatPath(Path) - Static method in class kafka.tier.state.ChecksumMigration
-
maybeRemovePreviousFormatPath is a helper util to delete (if exists) the previous format file.
- maybeSeekToEnd(String, Consumer<byte[], byte[]>, Set<TopicPartition>) - Method in class kafka.tools.StreamsResetter
-
- mayComplete(FileTierPartitionState.State, Optional<AbstractTierMetadata>) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.Initialization
-
- mayComplete(FileTierPartitionState.State, Optional<AbstractTierMetadata>) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.LeaderEpoch
-
- mayComplete(FileTierPartitionState.State, Optional<AbstractTierMetadata>) - Method in interface kafka.tier.state.FileTierPartitionState.MaterializationListener
-
Observe the unflushed FileTierPartitionState.State to determine if this listener can be completed after a flush.
- mayComplete(FileTierPartitionState.State, Optional<AbstractTierMetadata>) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- mayComplete(FileTierPartitionState.State, Optional<AbstractTierMetadata>) - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- mayContainTieredData() - Method in class kafka.tier.state.FileTierPartitionState
-
- mayContainTieredData() - Method in interface kafka.tier.state.TierPartitionState
-
Indicates if a partition may have some tiered data, essentially whether tiered storage is currently enabled or was enabled
earlier for this partition.
- mayEnableTiering(TopicPartition, LogConfig) - Method in class kafka.tier.state.TierPartitionStateFactory
-
- memberId() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- MemberMetadata(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- MemberMetadata() - Constructor for class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- members() - Method in class kafka.internals.generated.GroupMetadataValue
-
- MemoryLease(MemoryTracker, long, long) - Constructor for class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
- memoryPoolSizeBytes - Variable in class kafka.tier.fetcher.TierFetcherConfig
-
- MemoryTracker - Class in kafka.tier.fetcher
-
MemoryTracker tracks memory usage for the TierFetcher.
- MemoryTracker(Time, long) - Constructor for class kafka.tier.fetcher.MemoryTracker
-
- MemoryTracker(Time, Metrics, long) - Constructor for class kafka.tier.fetcher.MemoryTracker
-
- memoryTracker() - Method in class kafka.tier.fetcher.TierFetcher
-
- MemoryTracker.MemoryLease - Class in kafka.tier.fetcher
-
- Message - Class in kafka.restore.messages
-
- Message(int, String, int) - Constructor for class kafka.restore.messages.Message
-
Constructs new Request.
- MESSAGE_RESPONSE - Static variable in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- MessageEmitter - Interface in kafka.restore
-
- messageEmitter - Variable in class kafka.restore.statemachine.transitions.AbstractTransition
-
- messageId() - Method in class kafka.tier.domain.AbstractTierMetadata
-
Get a unique id for this message.
- messageId() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- messageId() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- messageId() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- messageId() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- messageId() - Method in class kafka.tier.domain.TierPartitionFence
-
- messageId() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- messageId() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- messageId() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- messageId() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- messageId() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- messageId() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- messageId() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- messageId() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- messageId(UUID) - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- messageId() - Method in class kafka.tier.serdes.InitLeader
-
- messageId(UUID) - Method in class kafka.tier.serdes.InitLeader
-
- messageId() - Method in class kafka.tier.serdes.PartitionDeleteComplete
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionDeleteComplete
-
- messageId() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- messageId() - Method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- messageId() - Method in class kafka.tier.serdes.PartitionFence
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionFence
-
- messageId() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionForceRestore
-
- messageId() - Method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- messageId(UUID) - Method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- messageIdAsBase64() - Method in class kafka.tier.domain.AbstractTierMetadata
-
Encode messageId with Base64
- MessageRequest - Class in kafka.restore.messages
-
Abstract Request class containing shared fields for all requests.
- MessageRequest(int, String, int) - Constructor for class kafka.restore.messages.MessageRequest
-
- MessageResponse - Class in kafka.restore.messages
-
Abstract Response class containing shared fields for all responses.
- MessageResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.MessageResponse
-
Constructs new Response.
- MessageResult - Enum in kafka.restore.messages
-
Possible results of a completed message request.
- MessageStatusCode - Enum in kafka.restore.messages
-
Possible status codes for a completed message request.
- META_FTPS_FILE_PATH - Static variable in class kafka.restore.statemachine.Constants
-
- META_NEW_FTPS_CONTENT_HASH - Static variable in class kafka.restore.statemachine.Constants
-
- META_NEW_FTPS_LOG_END_OFFSET - Static variable in class kafka.restore.statemachine.Constants
-
- META_NEW_FTPS_LOG_START_OFFSET - Static variable in class kafka.restore.statemachine.Constants
-
- META_RESTORE_SEGMENT_STATE_MAP - Static variable in class kafka.restore.statemachine.Constants
-
- metadata() - Method in class kafka.internals.generated.OffsetCommitValue
-
- metadata(long) - Method in class kafka.tier.state.FileTierPartitionState
-
- metadata(long) - Method in interface kafka.tier.state.TierPartitionState
-
Lookup the TierObjectMetadata which will contain data for a target offset.
- metadata - Variable in class kafka.tier.store.encryption.KeyContext
-
- METADATA_STATES_DIR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- METADATA_STATES_DIR_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- metadataStatesDir - Variable in class kafka.tier.tools.TierMetadataValidator
-
- metadataStatesDir - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- migrateFile(Path, Path, short) - Static method in class kafka.utils.checksum.CheckedFileIO
-
migrateFile provides migration between various checksum formats (such as ADLER -> NO_CHECKSUM or vice versa)
This method atomically migrates source file into destination file based on the destination checksum algorithm.
- MockInMemoryTierObjectStore - Class in kafka.tier.store
-
- MockInMemoryTierObjectStore(Time, MockInMemoryTierObjectStoreConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStore
-
- MockInMemoryTierObjectStore(Time, Metrics, MockInMemoryTierObjectStoreConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStore
-
- MockInMemoryTierObjectStore.UploadedObject - Class in kafka.tier.store
-
- MockInMemoryTierObjectStoreConfig - Class in kafka.tier.store
-
- MockInMemoryTierObjectStoreConfig() - Constructor for class kafka.tier.store.MockInMemoryTierObjectStoreConfig
-
- MockInMemoryTierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStoreConfig
-
- MockInMemoryTierObjectStoreConfig(String, Integer) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStoreConfig
-
- MockInMemoryTierObjectStoreConfig(Optional<String>, Optional<Integer>, String) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStoreConfig
-
- mostSignificantBits() - Method in class kafka.tier.serdes.UUID
-
- moveToCompleteSet(TopicPartition) - Method in class kafka.restore.statemachine.StateMachineController
-
- moveToFailMap(TopicPartition) - Method in class kafka.restore.statemachine.StateMachineController
-
- moveToInprogressMap(TopicPartition) - Method in class kafka.restore.statemachine.StateMachineController
-
- MultipleResponseHandler - Interface in kafka.restore.messages
-
A "complex" request from Restore Orchestrator sometimes can result in sending several sub requests to
external service.
- mutateBaseOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateChecksum(long) - Method in class kafka.tier.serdes.CheckedFileIOHeader
-
- mutateCompactDirtyStartOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- mutateEndOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- mutateEndOffsetDelta(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateEndPosition(long) - Method in class kafka.tier.serdes.CheckedFileIOHeader
-
- mutateFirstBatchTimestamp(long) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateGlobalMaterializedEpoch(int) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- mutateGlobalMaterializedOffset(long) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- mutateHasAbortedTxns(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateHasEpochState(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateHasProducerState(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateLocalMaterializedEpoch(int) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- mutateLocalMaterializedOffset(long) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- mutateMaxTimestamp(long) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateSize(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateStartOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- mutateState(TierObjectMetadata.State) - Method in class kafka.tier.domain.TierObjectMetadata
-
- mutateState(byte) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateStatus(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- mutateTierEpoch(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateTierEpoch(int) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- mutateUploadType(byte) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateVersion(byte) - Method in class kafka.tier.serdes.CheckedFileIOHeader
-
- mutateVersion(byte) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- mutateVersion(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- OBJECT_STORE_REQUEST_MAX_RETRIES - Static variable in class kafka.restore.schedulers.Constants
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.GcsTierObjectStore
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.S3TierObjectStore
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
-
- objectExists(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- objectId() - Method in class kafka.tier.domain.AbstractTierSegmentMetadata
-
A unique identifier for the segment.
- objectId() - Method in class kafka.tier.domain.TierObjectMetadata
-
Random ID associated with each TierObjectMetadata entry.
- objectId() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- objectId(UUID) - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- objectId() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- objectId(UUID) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- objectId() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- objectId(UUID) - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- objectId() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- objectId(UUID) - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- objectId() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- objectId(UUID) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- objectId() - Method in class kafka.tier.state.SegmentState
-
- objectId() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- objectIdAsBase64() - Method in class kafka.tier.domain.AbstractTierSegmentMetadata
-
Encode objectId with Base64
- objectIdAsBase64() - Method in class kafka.tier.domain.TierObjectMetadata
-
- objectIdAsBase64() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.LifecycleManagerStateMetadata
-
- ObjectMetadata(TopicIdPartition, UUID, int, long, boolean, boolean, boolean, TierObjectStore.OpaqueData) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- ObjectMetadata(TopicIdPartition, SegmentState) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- objectMetadata(Optional<String>, Optional<Integer>) - Method in interface kafka.tier.store.TierObjectStore.ObjectStoreMetadata
-
Converts an ObjectStoreMetadata to a map of metadata that may be useful to place on
objects in object storage, if this functionality is present in the object store
implementation of choice
- objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- ObjectState - Class in kafka.tier.serdes
-
- ObjectStoreManager - Class in kafka.restore.schedulers
-
ObjectStoreManager for scheduling and processing calls to ObjectStore APIs in an asynchronous manner.
- ObjectStoreManager(AsyncServiceSchedulerResultsReceiver, ObjectStorePool, int) - Constructor for class kafka.restore.schedulers.ObjectStoreManager
-
Constructs new ObjectStoreManager.
- ObjectStoreManager(AsyncServiceSchedulerResultsReceiver, ObjectStorePool) - Constructor for class kafka.restore.schedulers.ObjectStoreManager
-
Constructs new ObjectStoreManager.
- ObjectStorePool - Interface in kafka.restore.schedulers
-
ObjectStorePool interface for handling of ObjectStoreRequests.
- ObjectStorePoolImpl - Class in kafka.restore.schedulers
-
Connection pool for execution
ObjectStoreRequest
s that involve communicating wih Object Store.
- ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver, TierObjectStore, int) - Constructor for class kafka.restore.schedulers.ObjectStorePoolImpl
-
Constructs a new ObjectStorePool using the given parameters.
- ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver, int, TierObjectStore) - Constructor for class kafka.restore.schedulers.ObjectStorePoolImpl
-
Constructs a new ObjectStorePool using the given parameters.
- ObjectStoreRequest - Class in kafka.restore.messages
-
Abstract ObjectStoreRequest class for all requests made to ObjectStoreManager
- ObjectStoreRequest(int, String, int) - Constructor for class kafka.restore.messages.ObjectStoreRequest
-
Constructs a new ObjectStoreRequest.
- ObjectStoreResponse - Class in kafka.restore.messages
-
- ObjectStoreResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.ObjectStoreResponse
-
Constructs new ObjectStoreResponse.
- ObjectStoreUtils - Class in kafka.tier.backupObjectLifecycle
-
- ObjectStoreUtils() - Constructor for class kafka.tier.backupObjectLifecycle.ObjectStoreUtils
-
- ObjectStoreUtils.DeletionRecord - Class in kafka.tier.backupObjectLifecycle
-
- observerPromotionPolicy() - Method in class kafka.common.TopicPlacement
-
- observers() - Method in class kafka.common.TopicPlacement
-
- of(int, Map<String, String>) - Static method in class kafka.common.TopicPlacement.ConstraintCount
-
- of(int, Optional<Map<String, String>>) - Static method in class kafka.common.TopicPlacement.Replica
-
Returns a Replica from the id and set of attributes.
- offset() - Method in class kafka.internals.generated.OffsetCommitValue
-
- offset() - Method in class kafka.tier.serdes.OffsetAndEpoch
-
- offset() - Method in class kafka.tier.state.OffsetAndEpoch
-
- OffsetAndEpoch - Class in kafka.tier.serdes
-
- OffsetAndEpoch() - Constructor for class kafka.tier.serdes.OffsetAndEpoch
-
- OffsetAndEpoch - Class in kafka.tier.state
-
- OffsetAndEpoch(long, Optional<Integer>) - Constructor for class kafka.tier.state.OffsetAndEpoch
-
- OffsetAndEpoch(OffsetAndEpoch) - Constructor for class kafka.tier.state.OffsetAndEpoch
-
- offsetCacheExpirationMs - Variable in class kafka.tier.fetcher.TierFetcherConfig
-
- offsetCacheExpiryPeriodMs - Variable in class kafka.tier.fetcher.TierFetcherConfig
-
- offsetCacheSize - Variable in class kafka.tier.fetcher.TierFetcherConfig
-
- OffsetChange - Class in kafka.durability.events.serdes
-
- OffsetChange() - Constructor for class kafka.durability.events.serdes.OffsetChange
-
- OffsetCommitKey - Class in kafka.internals.generated
-
- OffsetCommitKey(Readable, short) - Constructor for class kafka.internals.generated.OffsetCommitKey
-
- OffsetCommitKey(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.OffsetCommitKey
-
- OffsetCommitKey() - Constructor for class kafka.internals.generated.OffsetCommitKey
-
- OffsetCommitValue - Class in kafka.internals.generated
-
- OffsetCommitValue(Readable, short) - Constructor for class kafka.internals.generated.OffsetCommitValue
-
- OffsetCommitValue(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.OffsetCommitValue
-
- OffsetCommitValue() - Constructor for class kafka.internals.generated.OffsetCommitValue
-
- offsetForTimestamp(CancellationContext, InputStream, long, int) - Method in class kafka.tier.fetcher.TierSegmentReader
-
Read the supplied input stream to find the first offset with a timestamp >= targetTimestamp
- offsetIndexFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- OffsetIndexFetchRequest - Class in kafka.tier.fetcher
-
- OffsetIndexFetchRequest() - Constructor for class kafka.tier.fetcher.OffsetIndexFetchRequest
-
- onAlteredExclusions(Set<Integer>, Set<Integer>) - Method in interface kafka.controller.ClusterBalanceManager
-
Notify the data balance manager of alterations in the set of active broker replica exclusions
- onBecomeFollower(TopicIdPartition) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
-
Fired when this topic partition becomes follower.
- onBecomeLeader(TopicIdPartition, int) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
-
Fired when this topic partition becomes leader.
- onBrokerLeadershipPriorityChange(boolean) - Method in interface kafka.controller.ClusterBalanceManager
-
Notify the data balance manager when the broker leadership priority changes.
- onBrokersFailure(Set<Integer>) - Method in interface kafka.controller.ClusterBalanceManager
-
Notify the balancer manager of brokers that are dead, either because they are shutdown or because
they are not known to controller anymore (no heartbeat).
- onBrokersStartup(Set<Integer>, Set<Integer>, AliveBrokersSnapshot) - Method in interface kafka.controller.ClusterBalanceManager
-
Notify the balance manager of newly-started brokers for it to take action on the event
(e.g schedule a broker add operation or cancel an ongoing broker removal)
- onCatchUpComplete() - Method in class kafka.tier.state.FileTierPartitionState
-
- onCatchUpComplete() - Method in interface kafka.tier.state.TierPartitionState
-
Mark catchup completed for tier partition state.
- onDelete(TopicIdPartition) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
-
Fired when this topic partition is deleted.
- ongoingReductionMinDeletionTimestamp() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- onMetricAdded(MetricName, Metric) - Method in class kafka.metrics.FilteringJmxReporter
-
- opaqueData() - Method in class kafka.tier.domain.TierObjectMetadata
-
- opaqueData() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- opaqueData() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- opaqueData(OpaqueDataField) - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- opaqueData() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- opaqueData(OpaqueDataField) - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- opaqueData() - Method in class kafka.tier.state.SegmentState
-
- opaqueData() - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- opaqueData() - Method in class kafka.tier.store.TierObjectStore.LifecycleManagerStateMetadata
-
- opaqueData() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- opaqueData() - Method in interface kafka.tier.store.TierObjectStore.ObjectStoreMetadata
-
- opaqueData() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- OpaqueDataField - Class in kafka.tier.serdes
-
- OpaqueDataField() - Constructor for class kafka.tier.serdes.OpaqueDataField
-
- open(Path, boolean, OpenOption...) - Static method in class kafka.utils.checksum.CheckedFileIO
-
Opens a file and returns a CheckedFileIO instance to access the file.
- open(Path, OpenOption...) - Static method in class kafka.utils.checksum.CheckedFileIO
-
- openOrCreate(Path, Algorithm, short, boolean, OpenOption...) - Static method in class kafka.utils.checksum.CheckedFileIO
-
Opens or creates a file, returning a CheckedFileIO instance to access the file.
- openOrCreate(Path, Algorithm, short, OpenOption...) - Static method in class kafka.utils.checksum.CheckedFileIO
-
- operatorContext() - Method in class kafka.restore.operators.RestorePartitionOperator
-
- OperatorUtil - Class in kafka.restore.operators
-
- OperatorUtil() - Constructor for class kafka.restore.operators.OperatorUtil
-
- OrchestratorStatus - Enum in kafka.restore
-
- overrideMap(Map<Integer, String>) - Method in class kafka.common.ReplicaExclusionCache
-
- parse(String) - Static method in class kafka.common.TopicPlacement
-
- parseFencingInformation(List<String>) - Static method in class kafka.tier.tools.RecoveryUtils
-
Converts a list of formatted TopicIdPartition strings to a list of TopicIdPartition.
- partition() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- partition() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- partition() - Method in class kafka.durability.events.serdes.EventKey
-
- partition() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- partition() - Method in class kafka.internals.generated.OffsetCommitKey
-
- partition - Variable in class kafka.restore.db.PartitionRestoreContext
-
- PARTITION - Static variable in class kafka.restore.statemachine.Constants
-
- partition() - Method in class kafka.tier.serdes.TierKafkaKey
-
- partition - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- partition() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- partition - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- partition() - Method in class kafka.tier.TopicIdPartition
-
- PARTITION_CONFIG - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- PARTITION_DOC - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- PARTITION_FENCED - Static variable in class kafka.restore.statemachine.api.State
-
- PARTITION_FILE_CONFIG - Static variable in class kafka.restore.RestoreConfig
-
- PARTITION_LEADER - Static variable in class kafka.restore.statemachine.Constants
-
- PARTITION_PARAM_NAME - Static variable in class kafka.restore.schedulers.Constants
-
- PARTITION_REPLICAS - Static variable in class kafka.restore.statemachine.Constants
-
- PARTITION_RESTORE_CONTEXT - Static variable in class kafka.restore.statemachine.Constants
-
- PARTITION_RESTORED - Static variable in class kafka.restore.statemachine.api.State
-
- PARTITION_STATUS_INVALID - Static variable in class kafka.restore.schedulers.Constants
-
Invalid tier partition status
- PartitionConfig - Class in kafka.restore.configmap
-
- PartitionConfig() - Constructor for class kafka.restore.configmap.PartitionConfig
-
- PartitionConfig(int, NodeConfig) - Constructor for class kafka.restore.configmap.PartitionConfig
-
- partitionCreationOffsetAndEpoch() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- partitionCreationOffsetAndEpoch() - Method in class kafka.tier.serdes.InitLeader
-
- partitionCreationOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.InitLeader
-
- PartitionDeleteComplete - Class in kafka.tier.serdes
-
- PartitionDeleteComplete() - Constructor for class kafka.tier.serdes.PartitionDeleteComplete
-
- PartitionDeleteInitiate - Class in kafka.tier.serdes
-
- PartitionDeleteInitiate() - Constructor for class kafka.tier.serdes.PartitionDeleteInitiate
-
- PartitionDeletePreInitiate - Class in kafka.tier.serdes
-
- PartitionDeletePreInitiate() - Constructor for class kafka.tier.serdes.PartitionDeletePreInitiate
-
- partitionError - Variable in class kafka.restore.db.Job
-
- PartitionFence - Class in kafka.tier.serdes
-
- PartitionFence() - Constructor for class kafka.tier.serdes.PartitionFence
-
- PartitionFencedToFtpsFetchedTransition - Class in kafka.restore.statemachine.transitions
-
- PartitionFencedToFtpsFetchedTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.PartitionFencedToFtpsFetchedTransition
-
- PartitionForceRestore - Class in kafka.tier.serdes
-
- PartitionForceRestore() - Constructor for class kafka.tier.serdes.PartitionForceRestore
-
- partitionId(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicPartitioner
-
Determine the Tier Topic partition that should contain metadata for a given tiered
TopicIdPartition
- partitionIds() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- PartitionInfo - Class in kafka.durability.db.serdes
-
- PartitionInfo() - Constructor for class kafka.durability.db.serdes.PartitionInfo
-
- partitionLeader - Variable in class kafka.restore.db.PartitionRestoreContext
-
- PartitionLogRangeValidator - Class in kafka.restore.schedulers
-
It is a wrapper class for the method of calling Kafka API to fetch Partition Status.
- PartitionLogRangeValidator(CloseableHttpClient, String, int, int, long, long, ThreadPoolExecutor) - Constructor for class kafka.restore.schedulers.PartitionLogRangeValidator
-
- partitionReassignmentsStatus() - Method in class kafka.common.BrokerAdditionDescriptionInternal
-
- partitionReassignmentsStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- PartitionReassignmentsStatusV1 - Enum in kafka.common
-
This is the very first version of the partition reassignments subtask status that tracks
draining replicas out of the broker to be removed.
- partitionReplicas - Variable in class kafka.restore.db.PartitionRestoreContext
-
- PartitionRestoreContext - Class in kafka.durability.restore.db.serdes
-
- PartitionRestoreContext() - Constructor for class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- PartitionRestoreContext - Class in kafka.restore.db
-
- PartitionRestoreContext(String, int, int, List<Integer>, long, PartitionRestoreContext.RestoreStatus, PartitionRestoreContext.RestoreState) - Constructor for class kafka.restore.db.PartitionRestoreContext
-
- PartitionRestoreContext.RestoreState - Enum in kafka.restore.db
-
- PartitionRestoreContext.RestoreStatus - Enum in kafka.restore.db
-
- partitionRestoreContextMap - Variable in class kafka.restore.db.Job
-
- partitionRestoreContexts(int) - Method in class kafka.durability.restore.db.serdes.Job
-
- partitionRestoreContexts(PartitionRestoreContext, int) - Method in class kafka.durability.restore.db.serdes.Job
-
- partitionRestoreContextsLength() - Method in class kafka.durability.restore.db.serdes.Job
-
- PartitionRestoredToRestoreStartOffsetEventSentTransition - Class in kafka.restore.statemachine.transitions
-
- PartitionRestoredToRestoreStartOffsetEventSentTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.PartitionRestoredToRestoreStartOffsetEventSentTransition
-
- partitionRestoreStatusMap() - Method in class kafka.restore.db.Job
-
- partitions(int) - Method in class kafka.durability.db.serdes.TopicInfo
-
- partitions(PartitionInfo, int) - Method in class kafka.durability.db.serdes.TopicInfo
-
- partitions(String, int) - Static method in class kafka.tier.topic.TierTopicManager
-
- partitionsLength() - Method in class kafka.durability.db.serdes.TopicInfo
-
- PartitionsSchema(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- PartitionsSchema() - Constructor for class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- PartitionStatusFetcher - Class in kafka.restore.schedulers
-
It is a wrapper class for the method of calling Kafka API to fetch Partition Status.
- PartitionStatusFetcher(CloseableHttpClient, String, int, int, int, ThreadPoolExecutor) - Constructor for class kafka.restore.schedulers.PartitionStatusFetcher
-
- PartitionUnfreezeLogStartOffset - Class in kafka.tier.serdes
-
- PartitionUnfreezeLogStartOffset() - Constructor for class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- path() - Method in class kafka.restore.operators.SegmentStateAndPath
-
- path() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- path() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- pause() - Method in class kafka.restore.RestoreOrchestrator
-
Pauses the RestoreOrchestrator.
- pause() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Pauses the Async Service Scheduler.
- pause() - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
Pauses AsyncTaskScheduler.
- pause() - Method in class kafka.restore.schedulers.KafkaManager
-
Pauses KafkaManager.
- pause() - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Pauses ObjectStoreManager.
- payloadBuffer() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- payloadBuffer() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- payloadBuffer() - Method in class kafka.tier.domain.TierObjectMetadata
-
Returns the internal Flatbuffers representation backing this TierObjectMetadata.
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionFence
-
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- payloadBuffer() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- payloadBuffer() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- payloadBuffer() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- payloadBuffer() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- payloadBuffer() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- payloadBuffer() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- payloadSize() - Method in class kafka.tier.domain.TierObjectMetadata
-
- PendingFetch - Class in kafka.tier.fetcher
-
- PendingFetch(CancellationContext, TierObjectStore, FetchOffsetCache, Optional<TierFetcherMetrics>, TierObjectStore.ObjectMetadata, Consumer<DelayedOperationKey>, long, int, int, IsolationLevel, MemoryTracker, List<TopicPartition>, Time) - Constructor for class kafka.tier.fetcher.PendingFetch
-
- PendingOffsetForTimestamp - Class in kafka.tier.fetcher
-
- PermanentException - Exception in kafka.restore.schedulers
-
- PermanentException(String) - Constructor for exception kafka.restore.schedulers.PermanentException
-
- pickOneNewPartitionToStartRestore() - Method in class kafka.restore.statemachine.StateMachineController
-
- pollDuration - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- poolSize() - Method in class kafka.tier.fetcher.MemoryTracker
-
- position() - Method in class kafka.restore.operators.SegmentStateIterator
-
- position() - Method in class kafka.tier.state.FileTierPartitionIterator
-
- position() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- position(long) - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- position() - Method in class kafka.utils.checksum.CheckedFileIO
-
Returns this channel's file relative position.
- position(long) - Method in class kafka.utils.checksum.CheckedFileIO
-
Sets this channel's file position from the input relative position.
- position() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- position(long) - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- positionFor(int) - Method in class kafka.tier.TierTopicManagerCommitter
-
Return the current position and epoch for the given tier topic partition.
- positionForOffset(CancellationContext, InputStream, long, int) - Method in class kafka.tier.fetcher.TierSegmentReader
-
- prefix - Variable in class kafka.tier.store.MockInMemoryTierObjectStoreConfig
-
- prefix - Variable in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
- prefix() - Method in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
- prefixWithTenant(String, TopicPartition) - Static method in class kafka.common.TenantHelpers
-
- prepPutSegment() - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- prepPutSegment() - Method in class kafka.tier.store.GcsTierObjectStore
-
- prepPutSegment() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- prepPutSegment() - Method in class kafka.tier.store.S3TierObjectStore
-
- prepPutSegment() - Method in interface kafka.tier.store.TierObjectStore
-
- prepPutSegment() - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- previousFormatPath(Path) - Static method in class kafka.tier.state.ChecksumMigration
-
previousFormatPath is a helper util to generate the path for previous format path.
- previousMetadataBeforeOffset(long) - Method in class kafka.tier.state.FileTierPartitionState
-
- previousMetadataBeforeOffset(long) - Method in interface kafka.tier.state.TierPartitionState
-
Get the in-memory metadata for the immediate previous segment (even beyond retention) to target startOffset
- previousObjectId() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- previousObjectId() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- previousObjectId(UUID) - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- previousStatus() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
-
- previousStatusLastUpdateTimeMs() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
-
- process(AbstractTierMetadata, OffsetAndEpoch) - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
Process metadata for this context.
- processRequestFromRequestQueue(MessageRequest) - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
- processRequestFromRequestQueue(MessageRequest) - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
Handles a request that has been pulled from the request queue, constructing the Runnable and submitting it to the
thread pool.
- processRequestFromRequestQueue(MessageRequest) - Method in class kafka.restore.schedulers.DryrunAsyncTaskScheduler
-
- processRequestFromRequestQueue(MessageRequest) - Method in class kafka.restore.schedulers.KafkaManager
-
Processes request that was pulled from the request queue.
- processRequestFromRequestQueue(MessageRequest) - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Processes a request that was pulled from the request queue.
- processRestoreEvents(AbstractTierMetadata, Optional<ByteBuffer>, TierPartitionStatus, OffsetAndEpoch) - Method in class kafka.tier.state.FileTierPartitionState
-
- processRestoreEvents(AbstractTierMetadata, Optional<ByteBuffer>, TierPartitionStatus, OffsetAndEpoch) - Method in interface kafka.tier.state.TierPartitionState
-
Processes one of the recovery events TierPartitionForceRestore or TierPartitionUnfreezeLogStartOffset.
- processRestoreEvents(AbstractTierMetadata, TierPartitionStatus, OffsetAndEpoch, Optional<ByteBuffer>) - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
Process restore events for this context
- processUnfreezeLogStartOffset(TierPartitionUnfreezeLogStartOffset, TierPartitionStatus, OffsetAndEpoch) - Method in class kafka.tier.state.FileTierPartitionState
-
Unfreeze log start offset at the MergedLog.
- producerEpoch() - Method in class kafka.internals.generated.TransactionLogValue
-
- producerId() - Method in class kafka.internals.generated.TransactionLogValue
-
- producerStateFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- properties(TierTopicManagerConfig, String) - Static method in class kafka.tier.client.TierTopicProducerSupplier
-
- props - Variable in class kafka.tier.tools.TierMetadataValidator
-
- protocol() - Method in class kafka.internals.generated.GroupMetadataValue
-
- protocolType() - Method in class kafka.internals.generated.GroupMetadataValue
-
- put(UUID, long, int, OptionalInt) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
-
- put(UUID, long, FetchOffsetMetadata) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
-
- putBackedUpObjectsListBufToObjectStore(StateManagerConfig, ByteBuffer, String, String) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Put the backup objects list buffer at the object store
- putBuf(String, Map<String, String>, ByteBuffer) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- putBuf(String, Map<String, String>, ByteBuffer) - Method in class kafka.tier.store.GcsTierObjectStore
-
- putBuf(String, Map<String, String>, ByteBuffer) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- putBuf(String, Map<String, String>, ByteBuffer) - Method in class kafka.tier.store.S3TierObjectStore
-
- putBuf(String, Map<String, String>, ByteBuffer) - Method in interface kafka.tier.store.TierObjectStore
-
- putBuf(String, Map<String, String>, ByteBuffer) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.GcsTierObjectStore
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.S3TierObjectStore
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in interface kafka.tier.store.TierObjectStore
-
- putInMemorySegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<ByteBuffer>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- putLatency() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.GcsTierObjectStore
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.S3TierObjectStore
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
-
- putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.GcsTierObjectStore
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.S3TierObjectStore
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in interface kafka.tier.store.TierObjectStore
-
- putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- putStateBufToObjectStore(StateManagerConfig, ByteBuffer) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Puts the lifecycle manager state buffer at the object store
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaKey
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.ComputedQuotaValue
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataKey
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitKey
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitValue
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogKey
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- read(Readable, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue
-
- read(TopicIdPartition, CheckedFileIO, long) - Static method in class kafka.tier.state.FileTierPartitionStateUtils
-
Perform a point read of a TierObjectMetadata at a particular position in a
TierPartitionState's CheckedFileIO instance
- read() - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- read(byte[]) - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- read(byte[], int, int) - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- read(ByteBuffer, long) - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- read(ByteBuffer, long) - Method in class kafka.utils.checksum.CheckedFileIO
-
Read data from the channel to the given byte buffer from the input relative position until there are no bytes
remaining in the buffer or the end of the file has been reached.
- read(ByteBuffer, long) - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- readBatch(InputStream, int) - Method in class kafka.tier.fetcher.TierSegmentReader
-
Reads one full batch from an InputStream.
- readHeader(CheckedFileIO) - Static method in class kafka.tier.state.FileTierPartitionState
-
- readInto(CancellationContext, InputStream, long, long) - Static method in class kafka.tier.fetcher.TierAbortedTxnReader
-
Read aborted transaction markers from the supplied inputstream
- readInto(CancellationContext, InputStream, ByteBuffer, int) - Method in class kafka.tier.fetcher.TierSegmentReader
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- readJsonFromFile(Path) - Static method in class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
-
- readRecords(CancellationContext, Optional<MemoryTracker.MemoryLease>, InputStream, int, long, int, int) - Method in class kafka.tier.fetcher.TierSegmentReader
-
Loads records from a given InputStream up to maxBytes.
- rebalanceTimeout() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- receivedAllResponses() - Method in interface kafka.restore.messages.MultipleResponseHandler
-
- receivedAllResponses() - Method in class kafka.restore.schedulers.RestoreObjectMultipleResponseHandler
-
- ReclaimableMemoryRecords - Class in kafka.tier.fetcher
-
- ReclaimableMemoryRecords(ByteBuffer, Optional<MemoryTracker.MemoryLease>) - Constructor for class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- reconcile(Map<UUID, SegmentState>) - Method in class kafka.restore.operators.ReconcilePartitionOperator
-
To make sure there is no holes in the segment chain, the logic to reconcile are:
- Find the segment with largest tierEpoch + endOffset (call it max segment) from the input segments,
- then flip all the segments before the max segment's state to SEGMENT_FENCED
By marking the segment's state into SEGMENT_FENCED, Kafka will take care of the garbage collecting task
for the segments after FTPS file injection.
- ReconcileFtpsRequest - Class in kafka.restore.messages
-
Request of type KAFKA_RECONCILE_FTPS to reconcile local version of FTPS file with results of attempted
restore.
- ReconcileFtpsRequest(int, String, int, String, long, Map<UUID, SegmentState>) - Constructor for class kafka.restore.messages.ReconcileFtpsRequest
-
Constructs new ReconcileFtpsRequest.
- ReconcileFtpsResponse - Class in kafka.restore.messages
-
- ReconcileFtpsResponse(int, String, int, int, MessageStatusCode, MessageResult) - Constructor for class kafka.restore.messages.ReconcileFtpsResponse
-
Constructs new ReconcileFtpsResponse.
- ReconcilePartitionOperator - Class in kafka.restore.operators
-
This operator's responsibility is to reconcile segment's state based on input segment list.
- ReconcilePartitionOperator(TopicPartition, String, long) - Constructor for class kafka.restore.operators.ReconcilePartitionOperator
-
- reconfigurableConfigs() - Method in class kafka.metrics.KafkaYammerMetrics
-
- reconfigurableConfigs - Static variable in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- reconfigurableConfigs() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- reconfigurableConfigs - Static variable in class kafka.tier.fetcher.TierFetcher
-
- reconfigurableConfigs() - Method in class kafka.tier.fetcher.TierFetcher
-
- reconfigure(Map<String, ?>) - Method in class kafka.metrics.KafkaYammerMetrics
-
- reconfigure(KafkaConfig, KafkaConfig) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- reconfigure(KafkaConfig, KafkaConfig) - Method in class kafka.tier.fetcher.TierFetcher
-
- record(String, long) - Method in class kafka.restore.RestoreMetricsManager
-
- recordBatchSize - Variable in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
-
- recordMessageIdBase64 - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- recordMessageIdBase64() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- recordOffset - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- recordOffset() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- recordPartition - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- recordPartition() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- records() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- records - Variable in class kafka.tier.fetcher.TierFetchResult
-
- RecordsAndNextBatchMetadata(ReclaimableMemoryRecords, TierSegmentReader.NextOffsetAndBatchMetadata) - Constructor for class kafka.tier.fetcher.TierSegmentReader.RecordsAndNextBatchMetadata
-
- recordTimestamp - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- recordTimestamp() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- recover() - Method in class kafka.restore.db.FileRestoreDB
-
- RECOVERY_REQUIRED_PROPERTIES - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RecoveryUtils - Class in kafka.tier.tools
-
Provides a set of static functions for recovery related tooling.
- RecoveryUtils() - Constructor for class kafka.tier.tools.RecoveryUtils
-
- reduceRatio() - Method in class kafka.tier.state.CompactStats
-
- ReductionInRetention(String, int, int, Long, Long, boolean) - Constructor for class kafka.tier.backupObjectLifecycle.LifecycleManager.ReductionInRetention
-
- reductionRecordTimestamp() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- register(TopicIdPartition, TierTopicConsumer.ClientCtx) - Method in class kafka.tier.topic.TierTopicConsumer
-
Register topic partition to be materialized.
- register(Map<TopicIdPartition, TierTopicConsumer.ClientCtx>) - Method in class kafka.tier.topic.TierTopicConsumer
-
Register topic partitions to be materialized.
- registerKeyFromObjectMetadata(Map<String, String>) - Method in class kafka.tier.store.encryption.EncryptionKeyManager
-
- release() - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
Release this MemoryLease, returning it back to the pool of available memory in the
MemoryTracker
- release() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- rematerialized() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- REMATERIALIZED_REPLICA_ID - Static variable in class kafka.tier.tools.common.ComparatorInfo
-
- removeMetrics() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManagerMetrics
-
Remove all the metrics.
- replica() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- ReplicaExclusionCache - Class in kafka.common
-
ReplicaExclusionCache
is a thread-safe cache containing the latest information about active broker replica exclusions in the cluster.
- ReplicaExclusionCache() - Constructor for class kafka.common.ReplicaExclusionCache
-
- replicaExclusions() - Method in class kafka.common.AliveBrokersSnapshot
-
Returns the active broker replica placement exclusions in the cluster
- replicaExclusionStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- ReplicaManagerBuilder - Class in kafka.server.builders
-
- ReplicaManagerBuilder() - Constructor for class kafka.server.builders.ReplicaManagerBuilder
-
- replicas() - Method in class kafka.common.TopicPlacement
-
- replicas(int) - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- replicas() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- replicasAsByteBuffer() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- replicasInByteBuffer(ByteBuffer) - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- replicasLength() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- replicationFactor() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
The replication factor of the topic.
- ReplicationTargetObjectId(Logger, TopicIdPartition, CompletableFuture<TierLogSegment>, UUID, long, long) - Constructor for class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- ReplicationTargetOffset(Logger, TopicIdPartition, CompletableFuture<TierLogSegment>, long) - Constructor for class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- reportFetchFtpsResponse(KafkaFetchFtpsRequest, MessageStatusCode, MessageResult, String) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Constructs a FetchFtpsResponse with the given params and reports it to the resultsReceiver.
- reportFetchFtpsResponse(KafkaFetchFtpsRequest, MessageStatusCode, MessageResult) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Constructs a FetchFtpsResponse with the given params and null ftpsFileName and reports it to the resultsReceiver.
- reportKafkaResponse(KafkaRequest, MessageStatusCode, MessageResult) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- reportKafkaValidateLogRangeResponse(KafkaRequest, MessageStatusCode, MessageResult) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- reportServiceSchedulerResponse(MessageResponse) - Method in class kafka.restore.RestoreOrchestrator
-
- reportServiceSchedulerResponse(MessageResponse) - Method in interface kafka.restore.schedulers.AsyncServiceSchedulerResultsReceiver
-
Passes along response from a previous request to an AsyncServiceScheduler.
- reportServiceSchedulerResponse(MessageResponse) - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Processes a response to a batched subRequest from ObjectStorePool.
- reportTierPartitionStatusResponse(KafkaRequest, MessageStatusCode, MessageResult) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- requestTimeoutMs - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- REQUIRED_PROPERTIES - Static variable in class kafka.tier.tools.TierMetadataComparator
-
- REQUIRED_PROPERTIES - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- reset() - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
Resets the Adler32 checksum to initial value of 1 and the length to 0
- resetOffsetsFromResetPlan(Consumer<byte[], byte[]>, Set<TopicPartition>, Map<TopicPartition, Long>) - Method in class kafka.tools.StreamsResetter
-
- resetOffsetsTo(Consumer<byte[], byte[]>, Set<TopicPartition>, Long) - Method in class kafka.tools.StreamsResetter
-
- resetToDatetime(Consumer<byte[], byte[]>, Set<TopicPartition>, Long) - Method in class kafka.tools.StreamsResetter
-
- restore() - Method in class kafka.restore.operators.RestorePartitionOperator
-
Iterate all segments, flip their state from (SEGMENT_DELETE_COMPLETE || SEGMENT_DELETE_INITIATE) to SEGMENT_UPLOAD_COMPLETE
return the SegmentPath map, which contains all the segments whose state had been flipped.
- Restore - Class in kafka.restore
-
- Restore() - Constructor for class kafka.restore.Restore
-
- restore() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- restore() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- restore(long, long) - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
Restores the state to a previously calculated checksum value and length for a given file.
- restore(long, long) - Method in interface kafka.utils.checksum.ChecksumWithInPlaceUpdate
-
Restores the state to a previously calculated checksum value and length for a given file.
- RESTORE_FROM_TIMESTAMP - Static variable in class kafka.restore.statemachine.Constants
-
- RESTORE_IN_PROGRESS - Static variable in class kafka.restore.RestoreMetricsManager
-
- RESTORE_INPUT_COMPARATOR_CONFIG - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_INPUT_COMPARATOR_DOC - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_INPUT_RAW_CONFIG - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_INPUT_RAW_DOC - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_OUTPUT_CONFIG - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_OUTPUT_DOC - Static variable in class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- RESTORE_REST_SERVER_PORT - Static variable in class kafka.restore.RestoreConfig
-
- RESTORE_START_OFFSET_EVENT_SENT - Static variable in class kafka.restore.statemachine.api.State
-
- RESTORE_STARTED - Static variable in class kafka.restore.RestoreMetricsManager
-
- RestoreComparatorInput(Map<String, RestoreInfo.ComparatorReplicaInfo>, RestoreInfo.ComparatorReplicaInfo, RestoreInfo.ComparatorReplicaInfo, FenceEventInfo) - Constructor for class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- RestoreComparatorOutput(RestoreInfo.RestoreComparatorInput, String) - Constructor for class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- RestoreConfig - Class in kafka.restore
-
- RestoreDB - Interface in kafka.restore.db
-
- RestoreDBStatusResponse - Class in kafka.restore.rest
-
- RestoreDBStatusResponse(List<StatusResponse>) - Constructor for class kafka.restore.rest.RestoreDBStatusResponse
-
- RestoreFiniteStateMachine - Class in kafka.restore.statemachine
-
- RestoreFiniteStateMachine(PartitionRestoreContext, Set<Transition>) - Constructor for class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- RestoreFtpsRequest - Class in kafka.restore.messages
-
Request of type KAFKA_RESTORE_FTPS to change the local version of FTPS to reflect the attempted restore.
- RestoreFtpsRequest(int, String, int, String, Date) - Constructor for class kafka.restore.messages.RestoreFtpsRequest
-
Constructs new RestoreFtpsRequest.
- RestoreFtpsResponse - Class in kafka.restore.messages
-
- RestoreFtpsResponse(int, String, int, int, MessageStatusCode, MessageResult, Map<UUID, SegmentStateAndPath>) - Constructor for class kafka.restore.messages.RestoreFtpsResponse
-
Construct new RestoreFtpsResponse.
- RestoreHandler - Class in kafka.restore.rest
-
Rest Handler to process kafka restore related requests
- RestoreHandler(RestoreMetricsManager, RestoreRestServer) - Constructor for class kafka.restore.rest.RestoreHandler
-
- RestoreInfo - Class in kafka.tier.tools.common
-
- RestoreInfo() - Constructor for class kafka.tier.tools.common.RestoreInfo
-
- RestoreInfo.ComparatorReplicaInfo - Class in kafka.tier.tools.common
-
- RestoreInfo.RestoreComparatorInput - Class in kafka.tier.tools.common
-
Encapsulates information of an event produced as an output by
the comparator tool.
- RestoreInfo.RestoreComparatorOutput - Class in kafka.tier.tools.common
-
Encapsulates information of an event that's processed by the
TierPartitionStateRestoreTrigger class as input for a state
restoration action.
- RestoreInfo.RestoreRawInput - Class in kafka.tier.tools.common
-
Encapsulates information of an event that's processed by the
TierPartitionStateRestoreTrigger class as input for a state
restoration action.
- RestoreInfo.RestoreRawOutput - Class in kafka.tier.tools.common
-
Encapsulates information of an event that's produced by the
TierPartitionStateRestoreTrigger class in response to a
RestoreRawInput event.
- RestoreInfo.UnfreezeTriggerOutput - Class in kafka.tier.tools.common
-
- restoreLogStartOffset() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- restoreLogStartOffset() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- RestoreMetricsManager - Class in kafka.restore
-
- RestoreMetricsUtil - Class in kafka.restore
-
- RestoreMetricsUtil() - Constructor for class kafka.restore.RestoreMetricsUtil
-
- restoreObjectByCopy() - Method in class kafka.restore.schedulers.CopyObjectOperator
-
A wrapper to send copy request to object store asynchronously
- restoreObjectByCopy(String, VersionInformation) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
-
- restoreObjectByCopy(String, VersionInformation) - Method in class kafka.tier.store.GcsTierObjectStore
-
- restoreObjectByCopy(String, VersionInformation) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- restoreObjectByCopy(String, VersionInformation) - Method in class kafka.tier.store.S3TierObjectStore
-
- restoreObjectByCopy(String, VersionInformation) - Method in interface kafka.tier.store.TierObjectStore
-
There are usually 2 ways to restore a deleted object:
- to remove the deleteMarker of the object to expose its last live version again as current version.
- restoreObjectByCopy(String, VersionInformation) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- RestoreObjectMultipleResponseHandler - Class in kafka.restore.schedulers
-
RestoreObjectsInStoreRequest is a "complex" request (see
MultipleResponseHandler
for explain what
a complex request means).
- RestoreObjectMultipleResponseHandler(RestoreObjectsInStoreRequest, AsyncServiceSchedulerResultsReceiver) - Constructor for class kafka.restore.schedulers.RestoreObjectMultipleResponseHandler
-
- RestoreObjectsInStoreRequest - Class in kafka.restore.messages
-
Request of type KAFKA_SEGMENT_RESTORE, to restore the given segments in object store.
- RestoreObjectsInStoreRequest(int, String, int, Map<UUID, String>) - Constructor for class kafka.restore.messages.RestoreObjectsInStoreRequest
-
Constructs new RestoreObjectsInStoreRequest.
- RestoreObjectsInStoreResponse - Class in kafka.restore.messages
-
- RestoreObjectsInStoreResponse(int, String, int, int, MessageStatusCode, MessageResult, Set<UUID>) - Constructor for class kafka.restore.messages.RestoreObjectsInStoreResponse
-
Constructs new RestoreObjectsInStoreResponse.
- restoreOffsetAndEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- restoreOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- restoreOffsetAndEpoch() - Method in class kafka.tier.state.Header
-
- RestoreOrchestrator - Class in kafka.restore
-
RestoreOrchestrator is the control center for kafka restore
RestoreDB provides RestoreOrchestrator with the list of TopicPartitions to be restored.
- RestoreOrchestrator(RestoreMetricsManager) - Constructor for class kafka.restore.RestoreOrchestrator
-
- RestoreOrchestrator(int, RestoreMetricsManager) - Constructor for class kafka.restore.RestoreOrchestrator
-
- RestorePartitionOperator - Class in kafka.restore.operators
-
The RestorePartitionOperator is for identifying the segments need be restored from object store.
- RestorePartitionOperator(TopicPartition, String, long) - Constructor for class kafka.restore.operators.RestorePartitionOperator
-
- RestorePartitionOperatorFactory - Class in kafka.restore
-
- RestorePartitionOperatorFactory() - Constructor for class kafka.restore.RestorePartitionOperatorFactory
-
- RestoreRawInput(FenceEventInfo, Path) - Constructor for class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- RestoreRawOutput(RestoreInfo.RestoreRawInput, String) - Constructor for class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- RestoreRestServer - Class in kafka.restore.rest
-
- RestoreRestServer(RestoreMetricsManager) - Constructor for class kafka.restore.rest.RestoreRestServer
-
- RestoreStartOffsetEventSentToStartOffsetRestoredTransition - Class in kafka.restore.statemachine.transitions
-
- RestoreStartOffsetEventSentToStartOffsetRestoredTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.RestoreStartOffsetEventSentToStartOffsetRestoredTransition
-
- restoreStartTime() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- RestoreTierPartitionState - Class in kafka.restore
-
This tool is for restoring segment's state in FTPS file based on timestamp input.
- RestoreTierPartitionState() - Constructor for class kafka.restore.RestoreTierPartitionState
-
- RestoreTopicListConfig - Class in kafka.restore.configmap
-
- RestoreTopicListConfig() - Constructor for class kafka.restore.configmap.RestoreTopicListConfig
-
- result - Variable in class kafka.tier.tools.TierMetadataValidator.OffsetValidationResult
-
- results() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
- resume() - Method in class kafka.restore.RestoreOrchestrator
-
Resumes the RestoreOrchestrator.
- resume() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Resumes the Async Service Scheduler.
- resume() - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
Resumes AsyncTaskScheduler.
- resume() - Method in class kafka.restore.schedulers.KafkaManager
-
Resumes KafkaManager.
- resume() - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Resumes ObjectStoreManager.
- retainRatio() - Method in class kafka.tier.state.CompactStats
-
- RETENTION_TIME - Static variable in class kafka.restore.configmap.ConfigmapUtil
-
- RetentionChange - Class in kafka.durability.events.serdes
-
- RetentionChange() - Constructor for class kafka.durability.events.serdes.RetentionChange
-
- retentionData(int) - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- retentionData(TopicRetentionData, int) - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- retentionDataLength() - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- retentionInDays() - Method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- retentionSize() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- retentionTime() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- retentionType() - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- retentionValue() - Method in class kafka.durability.events.serdes.StartOffsetChange
-
- retrieveObjectsEligibleForDeletion(Long, Map<String, Map<TopicIdPartition, List<LifecycleManager.BlobMetadata>>>) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
Iterate over the lists of blobs eligible for deletion and return the ones past their deletion time.
- RetryableException - Exception in kafka.restore.schedulers
-
- RetryableException(String) - Constructor for exception kafka.restore.schedulers.RetryableException
-
- run() - Method in class kafka.restore.schedulers.ThreadPoolMonitor
-
- run() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- run() - Method in class kafka.tier.fetcher.PendingFetch
-
- run() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
- run() - Method in class kafka.tier.tools.TierMetadataComparator
-
The core logic of the Comparator tool can be broken down into the following 4 steps:
1.
- run() - Method in class kafka.tier.tools.TierMetadataValidator
-
- run() - Method in class kafka.tier.tools.TierTopicMaterializationUtils
-
- run() - Method in class kafka.tier.topic.TierTopicConsumer
-
- run() - Method in class kafka.tier.topic.TierTopicManager
-
- run(String[]) - Method in class kafka.tools.StreamsResetter
-
- run(String[], Properties) - Method in class kafka.tools.StreamsResetter
-
- runRestoreJob(Job) - Method in class kafka.restore.RestoreOrchestrator
-
- s3AutoAbortThresholdBytes - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3Bucket - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3CredFilePath - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3EndpointOverride - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3ForcePathStyleAccess - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- S3ObjectStorePool - Class in kafka.restore.schedulers
-
- S3ObjectStorePool() - Constructor for class kafka.restore.schedulers.S3ObjectStorePool
-
- s3Prefix - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3Region - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SignerOverride - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SseAlgorithm - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SseCustomerEncryptionKey - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslEnabledProtocols - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslKeyPassword - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslKeyStoreLocation - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslKeyStorePassword - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslKeyStoreType - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslProtocol - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslTrustStoreLocation - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslTrustStorePassword - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- s3SslTrustStoreType - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- S3TierObjectStore - Class in kafka.tier.store
-
- S3TierObjectStore(S3TierObjectStoreConfig) - Constructor for class kafka.tier.store.S3TierObjectStore
-
- S3TierObjectStoreConfig - Class in kafka.tier.store
-
- S3TierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.S3TierObjectStoreConfig
-
- S3TierObjectStoreConfig(Optional<String>, Optional<Integer>, String, String, String, String, String, String, String, Integer, String, String, Boolean, String, String, String, String, Password, String, String, Password, String, Password) - Constructor for class kafka.tier.store.S3TierObjectStoreConfig
-
- s3UserAgentPrefix - Variable in class kafka.tier.store.S3TierObjectStoreConfig
-
- S3VersionInformation - Class in kafka.tier.store
-
- saveHttpResponseToFile(HttpResponse, String) - Static method in class kafka.restore.schedulers.SchedulerUtil
-
Save http response as a file
- scheduleBrokerRemoval(BrokerRemovalRequest, AliveBrokersSnapshot) - Method in interface kafka.controller.ClusterBalanceManager
-
Schedule a broker removal operation
- SchedulerUtil - Class in kafka.restore.schedulers
-
- SchedulerUtil() - Constructor for class kafka.restore.schedulers.SchedulerUtil
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.ComputedQuotaKey
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.ComputedQuotaValue
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.GroupMetadataValue
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.OffsetCommitKey
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.OffsetCommitValue
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.TransactionLogKey
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- SCHEMA_0 - Static variable in class kafka.internals.generated.TransactionLogValue
-
- SCHEMA_1 - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- SCHEMA_1 - Static variable in class kafka.internals.generated.GroupMetadataValue
-
- SCHEMA_1 - Static variable in class kafka.internals.generated.OffsetCommitKey
-
- SCHEMA_1 - Static variable in class kafka.internals.generated.OffsetCommitValue
-
- SCHEMA_2 - Static variable in class kafka.internals.generated.GroupMetadataKey
-
- SCHEMA_2 - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- SCHEMA_2 - Static variable in class kafka.internals.generated.GroupMetadataValue
-
- SCHEMA_2 - Static variable in class kafka.internals.generated.OffsetCommitValue
-
- SCHEMA_3 - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- SCHEMA_3 - Static variable in class kafka.internals.generated.GroupMetadataValue
-
- SCHEMA_3 - Static variable in class kafka.internals.generated.OffsetCommitValue
-
- SCHEMAS - Static variable in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- SCHEMAS - Static variable in class kafka.internals.generated.ComputedQuotaKey
-
- SCHEMAS - Static variable in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- SCHEMAS - Static variable in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- SCHEMAS - Static variable in class kafka.internals.generated.ComputedQuotaValue
-
- SCHEMAS - Static variable in class kafka.internals.generated.GroupMetadataKey
-
- SCHEMAS - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- SCHEMAS - Static variable in class kafka.internals.generated.GroupMetadataValue
-
- SCHEMAS - Static variable in class kafka.internals.generated.OffsetCommitKey
-
- SCHEMAS - Static variable in class kafka.internals.generated.OffsetCommitValue
-
- SCHEMAS - Static variable in class kafka.internals.generated.TransactionLogKey
-
- SCHEMAS - Static variable in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- SCHEMAS - Static variable in class kafka.internals.generated.TransactionLogValue
-
- SEGMENT_COMPACTED - Static variable in class kafka.tier.serdes.ObjectState
-
- SEGMENT_DELETE_COMPLETE - Static variable in class kafka.tier.serdes.ObjectState
-
- SEGMENT_DELETE_INITIATE - Static variable in class kafka.tier.serdes.ObjectState
-
- SEGMENT_FENCED - Static variable in class kafka.tier.serdes.ObjectState
-
- SEGMENT_UPLOAD_COMPLETE - Static variable in class kafka.tier.serdes.ObjectState
-
- SEGMENT_UPLOAD_INITIATE - Static variable in class kafka.tier.serdes.ObjectState
-
- segmentCountWithState(TierObjectMetadata.State) - Method in class kafka.restore.operators.FtpsSegmentView
-
- SegmentDeleteComplete - Class in kafka.tier.serdes
-
- SegmentDeleteComplete() - Constructor for class kafka.tier.serdes.SegmentDeleteComplete
-
- SegmentDeleteInitiate - Class in kafka.tier.serdes
-
- SegmentDeleteInitiate() - Constructor for class kafka.tier.serdes.SegmentDeleteInitiate
-
- segmentFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- segmentInMemoryMetadataRange(long, long) - Method in class kafka.tier.state.FileTierPartitionState
-
- segmentInMemoryMetadataRange(long, long) - Method in interface kafka.tier.state.TierPartitionState
-
List of all the segment (minimal) metadata whose startOffset is in the range (even if they are beyond retention).
- segments() - Method in class kafka.tier.state.FileTierPartitionState
-
- segments(long, long) - Method in class kafka.tier.state.FileTierPartitionState
-
- segments() - Method in interface kafka.tier.state.TierPartitionState
-
Get an iterator for all readable tiered segments.
- segments(long, long) - Method in interface kafka.tier.state.TierPartitionState
-
Get an iterator for all readable tiered segments in a given range.
- SEGMENTS_REPAIRED - Static variable in class kafka.restore.statemachine.api.State
-
- SegmentsRepairedToFtpsReconciledTransition - Class in kafka.restore.statemachine.transitions
-
- SegmentsRepairedToFtpsReconciledTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.SegmentsRepairedToFtpsReconciledTransition
-
- segmentState() - Method in class kafka.restore.operators.SegmentStateAndPath
-
- SegmentState - Class in kafka.tier.state
-
- SegmentState(TierObjectMetadata, long, long) - Constructor for class kafka.tier.state.SegmentState
-
- SegmentState(int, UUID, long, long, long, long, long, int, TierObjectMetadata.State, boolean, boolean, boolean, TierUploadType, TierObjectStore.OpaqueData, long) - Constructor for class kafka.tier.state.SegmentState
-
- SegmentStateAndPath - Class in kafka.restore.operators
-
- SegmentStateAndPath(SegmentState, String) - Constructor for class kafka.restore.operators.SegmentStateAndPath
-
- segmentStateByObjectID(UUID) - Method in class kafka.restore.operators.RestorePartitionOperator
-
- SegmentStateIterator - Class in kafka.restore.operators
-
- SegmentStateIterator(TopicIdPartition, CheckedFileIO, long) - Constructor for class kafka.restore.operators.SegmentStateIterator
-
- segmentStateList() - Method in class kafka.restore.operators.FtpsSegmentView
-
- segmentStateMap() - Method in class kafka.restore.operators.FtpsSegmentView
-
- SegmentUploadComplete - Class in kafka.tier.serdes
-
- SegmentUploadComplete() - Constructor for class kafka.tier.serdes.SegmentUploadComplete
-
- SegmentUploadInitiate - Class in kafka.tier.serdes
-
- SegmentUploadInitiate() - Constructor for class kafka.tier.serdes.SegmentUploadInitiate
-
- serializeBackupObjectsList(Map<TopicIdPartition, List<LifecycleManager.BlobMetadata>>) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Serialize the backup objects list
- serializeKey() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- serializeState(Long, long[], Map<String, Integer>, Map<String, LifecycleManager.ReductionInRetention>, Map<String, String>) - Static method in class kafka.tier.backupObjectLifecycle.StateManager
-
Serializes the lifecycle manager state data
- serializeValue() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- server - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- sessionTimeout() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setAlterIsrManager(AlterIsrManager) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setApiVersionManager(ApiVersionManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setAssignment(byte[]) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setAsyncTaskScheduler(AsyncTaskScheduler) - Method in class kafka.restore.RestoreOrchestrator
-
- setAuthorizer(Optional<Authorizer>) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setAutoTopicCreationManager(AutoTopicCreationManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setBrokerId(int) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- setBrokerId(int) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setBrokerTopicStats(BrokerTopicStats) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setBrokerTopicStats(BrokerTopicStats) - Method in class kafka.server.builders.LogManagerBuilder
-
- setBrokerTopicStats(BrokerTopicStats) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setCleanerConfig(CleanerConfig) - Method in class kafka.server.builders.LogManagerBuilder
-
- setClientHost(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setClientId(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setClusterId(String) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setClusterLinkAdminManager(ClusterLinkFactory.AdminManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setCommitTimestamp(long) - Method in class kafka.internals.generated.OffsetCommitValue
-
- setComputedBrokerQuotas(List<ComputedQuotaValue.ComputedBrokerQuota>) - Method in class kafka.internals.generated.ComputedQuotaValue
-
- setComputedQuotas(List<ComputedQuotaValue.ComputedQuota>) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- setConfig(KafkaConfig) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setConfig(KafkaConfig) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setConfigRepository(ConfigRepository) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setConfigRepository(ConfigRepository) - Method in class kafka.server.builders.LogManagerBuilder
-
- setCurrentStateTimestamp(long) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setDelayedDeleteRecordsPurgatory(DelayedOperationPurgatory<DelayedDeleteRecords>) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setDelayedElectLeaderPurgatoryParam(DelayedOperationPurgatory<DelayedElectLeader>) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setDelayedFetchPurgatory(DelayedOperationPurgatory<DelayedFetch>) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setDelayedListOffsetsPurgatory(DelayedOperationPurgatory<DelayedListOffsets>) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setDelayedProducePurgatory(DelayedOperationPurgatory<DelayedProduce>) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setDryRun(boolean) - Static method in class kafka.restore.RestoreConfig
-
- setEntityName(String) - Method in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- setEntityType(String) - Method in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- setException(Exception) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- setExpireTimestamp(long) - Method in class kafka.internals.generated.OffsetCommitValue
-
- setFetchManager(FetchManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setFlushCheckMs(long) - Method in class kafka.server.builders.LogManagerBuilder
-
- setFlushRecoveryOffsetCheckpointMs(long) - Method in class kafka.server.builders.LogManagerBuilder
-
- setFlushStartOffsetCheckpointMs(long) - Method in class kafka.server.builders.LogManagerBuilder
-
- setFromTimestamp(long) - Method in class kafka.restore.configmap.TopicConfig
-
- setGeneration(int) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setGroup(String) - Method in class kafka.internals.generated.GroupMetadataKey
-
- setGroup(String) - Method in class kafka.internals.generated.OffsetCommitKey
-
- setGroupCoordinator(GroupCoordinator) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setGroupInstanceId(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setHeader(Header) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- setHost(String) - Method in class kafka.restore.configmap.NodeConfig
-
- setHttpClient(CloseableHttpClient) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
For test.
- setId(int) - Method in class kafka.restore.configmap.NodeConfig
-
- setInitialDefaultConfig(LogConfig) - Method in class kafka.server.builders.LogManagerBuilder
-
- setInitialOfflineDirs(List<File>) - Method in class kafka.server.builders.LogManagerBuilder
-
- setInterBrokerProtocolVersion(ApiVersion) - Method in class kafka.server.builders.LogManagerBuilder
-
- setIsShuttingDown(AtomicBoolean) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setKafkaManager(KafkaManager) - Method in class kafka.restore.RestoreOrchestrator
-
- setKeepPartitionMetadataFile(boolean) - Method in class kafka.server.builders.LogManagerBuilder
-
- setLastUpdateTime(long) - Method in class kafka.common.BrokerAddStatus
-
- setLeader(String) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setLeader(NodeConfig) - Method in class kafka.restore.configmap.PartitionConfig
-
- setLeaderEpoch(int) - Method in class kafka.internals.generated.OffsetCommitValue
-
- setLocalMode(boolean) - Static method in class kafka.restore.RestoreConfig
-
- setLogDeletionMaxSegmentsPerRun(int) - Method in class kafka.server.builders.LogManagerBuilder
-
- setLogDirFailureChannel(LogDirFailureChannel) - Method in class kafka.server.builders.LogManagerBuilder
-
- setLogDirFailureChannel(LogDirFailureChannel) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setLogDirs(List<File>) - Method in class kafka.server.builders.LogManagerBuilder
-
- setLogManager(LogManager) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setMaxPidExpirationMs(int) - Method in class kafka.server.builders.LogManagerBuilder
-
- setMemberId(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setMembers(List<GroupMetadataValue.MemberMetadata>) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setMetadata(String) - Method in class kafka.internals.generated.OffsetCommitValue
-
- setMetadataCache(MetadataCache) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setMetadataCache(MetadataCache) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setMetadataSupport(MetadataSupport) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setMetrics(Metrics) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setMetrics(Metrics) - Method in class kafka.server.builders.LogManagerBuilder
-
- setMetrics(Metrics) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setName(String) - Method in class kafka.restore.configmap.TopicConfig
-
- setObjectStoreManager(ObjectStoreManager) - Method in class kafka.restore.RestoreOrchestrator
-
- setObjectStoreRetryWaitInMs(long) - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
- setOffset(long) - Method in class kafka.internals.generated.OffsetCommitValue
-
- setPartition(int) - Method in class kafka.internals.generated.OffsetCommitKey
-
- setPartition(int) - Method in class kafka.restore.configmap.PartitionConfig
-
- setPartitionConfigs(List<PartitionConfig>) - Method in class kafka.restore.configmap.TopicConfig
-
- setPartitionIds(List<Integer>) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- setPoolSize(long) - Method in class kafka.tier.fetcher.MemoryTracker
-
Set a new pool size for the Memory Tracker.
- setPort(int) - Method in class kafka.restore.configmap.NodeConfig
-
- setProducerEpoch(short) - Method in class kafka.internals.generated.TransactionLogValue
-
- setProducerId(long) - Method in class kafka.internals.generated.TransactionLogValue
-
- setProperty(String, String) - Static method in class kafka.restore.RestoreConfig
-
- setProtocol(String) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setProtocolType(String) - Method in class kafka.internals.generated.GroupMetadataValue
-
- setQuota(double) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- setQuotaCoordinator(QuotaCoordinator) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setQuotaEntity(List<ComputedQuotaKey.EntityData>) - Method in class kafka.internals.generated.ComputedQuotaKey
-
- setQuotaManagers(QuotaFactory.QuotaManagers) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setQuotas(QuotaFactory.QuotaManagers) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setQuotaType(String) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- setRebalanceTimeout(int) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setRecoveryThreadsPerDataDir(int) - Method in class kafka.server.builders.LogManagerBuilder
-
- setReplicaManager(ReplicaManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setReplicas(List<NodeConfig>) - Method in class kafka.restore.configmap.PartitionConfig
-
- setRequestChannel(RequestChannel) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setRequestID(int) - Method in class kafka.restore.messages.MessageResponse
-
- setRestoreDB(RestoreDB) - Method in class kafka.restore.rest.RestoreHandler
-
- setRestoreDB(RestoreDB) - Method in class kafka.restore.rest.RestoreRestServer
-
- setRetentionCheckMs(long) - Method in class kafka.server.builders.LogManagerBuilder
-
- setScheduler(Scheduler) - Method in class kafka.server.builders.LogManagerBuilder
-
- setScheduler(Scheduler) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setSessionTimeout(int) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setStartTime(long) - Method in class kafka.common.BrokerAddStatus
-
- setStatusQueryRetryWaitInMs(long) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- setSubscription(byte[]) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- setThreadNamePrefix(String) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setThrottled(boolean) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- setTierDeletedPartitionsCoordinator(TierDeletedPartitionsCoordinator) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setTieredPartitionRecoveryWorkflowCb(Consumer<TierPartitionState.RecoveryOperation>) - Method in class kafka.tier.state.FileTierPartitionState
-
- setTieredPartitionRecoveryWorkflowCb(Consumer<TierPartitionState.RecoveryOperation>) - Method in interface kafka.tier.state.TierPartitionState
-
Sets the callback function used by tier partition state to communicate to the MergedLog layer during recovery of
a tiered partition.
- setTieringDisabled() - Method in class kafka.tier.state.FileTierPartitionState
-
- setTieringDisabled() - Method in interface kafka.tier.state.TierPartitionState
-
Reset the tier(ing) enabled flag at TierPartitionState.
- setTieringEnabled() - Method in class kafka.tier.state.FileTierPartitionState
-
- setTieringEnabled() - Method in interface kafka.tier.state.TierPartitionState
-
Called when tiering is enabled for this tier topic partition.
- setTierLogComponents(TierLogComponents) - Method in class kafka.server.builders.LogManagerBuilder
-
- setTierReplicaComponents(TierReplicaComponents) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setTierStateCheckpointMs(int) - Method in class kafka.server.builders.LogManagerBuilder
-
- setTime(Time) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setTime(Time) - Method in class kafka.server.builders.LogManagerBuilder
-
- setTime(Time) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- setTokenManager(DelegationTokenManager) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setTopic(String) - Method in class kafka.internals.generated.OffsetCommitKey
-
- setTopic(String) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- setTopicConfigs(List<TopicConfig>) - Method in class kafka.restore.configmap.RestoreTopicListConfig
-
- setTopicId(UUID) - Method in class kafka.tier.state.FileTierPartitionState
-
- setTopicId(UUID) - Method in interface kafka.tier.state.TierPartitionState
-
Sets the TopicIdPartition for this TierPartitionState.
- setTransactionalId(String) - Method in class kafka.internals.generated.TransactionLogKey
-
- setTransactionLastUpdateTimestampMs(long) - Method in class kafka.internals.generated.TransactionLogValue
-
- setTransactionPartitions(List<TransactionLogValue.PartitionsSchema>) - Method in class kafka.internals.generated.TransactionLogValue
-
- setTransactionStartTimestampMs(long) - Method in class kafka.internals.generated.TransactionLogValue
-
- setTransactionStatus(byte) - Method in class kafka.internals.generated.TransactionLogValue
-
- setTransactionTimeoutMs(int) - Method in class kafka.internals.generated.TransactionLogValue
-
- setTxnCoordinator(TransactionCoordinator) - Method in class kafka.server.builders.KafkaApisBuilder
-
- setupConsumer(TierTopicMaterializationToolConfig) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
-
- setUsage(double) - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- setValidationSuccess(boolean) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- setZkClient(KafkaZkClient) - Method in class kafka.server.builders.ReplicaManagerBuilder
-
- shiftOffsetsBy(Consumer<byte[], byte[]>, Set<TopicPartition>, long) - Method in class kafka.tools.StreamsResetter
-
- shouldShutdown - Variable in class kafka.common.BrokerRemovalRequest
-
- shutdown() - Method in interface kafka.controller.ClusterBalanceManager
-
Notify node shutdown
- shutdown() - Method in class kafka.restore.RestoreOrchestrator
-
Shuts down Restore Orchestrator, cleaning up resources.
- shutdown() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Shuts down Async Service Scheduler, cleaning up resources.
- shutdown() - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
Shuts down the AsyncTaskScheduler, cleaning up resources.
- shutdown() - Method in interface kafka.restore.schedulers.KafkaConnectionPool
-
Shuts down Kafka connection pool.
- shutdown() - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Shuts down KafkaConnectionPool resources.
- shutdown() - Method in class kafka.restore.schedulers.KafkaManager
-
Shuts down the KafkaManager, cleaning up resources.
- shutdown() - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Shuts down the ObjectStoreManager, cleaning up resources.
- shutdown() - Method in interface kafka.restore.schedulers.ObjectStorePool
-
Shuts down ObjectStorePool, cleaning up all resources.
- shutdown() - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
Shuts down the ObjectStorePool.
- shutdown() - Method in class kafka.restore.schedulers.S3ObjectStorePool
-
- shutdown() - Method in class kafka.restore.schedulers.ThreadPoolMonitor
-
- shutdown() - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- shutdown() - Method in class kafka.tier.topic.TierTopicConsumer
-
- shutdown() - Method in class kafka.tier.topic.TierTopicManager
-
Shutdown the tier topic manager.
- shutdownScheduled() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
Denotes whether this broker removal operation had the shutdown broker step enabled to run.
- size() - Method in class kafka.durability.events.serdes.RetentionChange
-
- size() - Method in class kafka.tier.domain.TierObjectMetadata
-
- size() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- size() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
-
- size() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- size() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- size() - Method in class kafka.tier.state.Header
-
- size() - Method in class kafka.tier.state.SegmentState
-
- size() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- size() - Method in class kafka.utils.checksum.CheckedFileIO
-
Size of file channel based on relative position.
- size() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- sizeInBytes() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- skip(long) - Method in class kafka.tier.store.AutoAbortingGenericInputStream
-
- SNAPSHOT_STATES_FILES - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- SNAPSHOT_STATES_FILES_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- snapshotPositions() - Method in class kafka.tier.topic.TierTopicConsumer
-
Takes and returns a snapshot of the current positions for all tier topic partitions.
- sourceObjectIds(int) - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- sourceObjectIds(UUID, int) - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- sourceObjectIdsGet(int) - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- sourceObjectIdsLength() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- sourceObjectIdsLength() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- SRC_PARTIITON_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- SRC_PARTITION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- SRC_TOPIC_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- SRC_TOPIC_ID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- start() - Method in class kafka.durability.db.serdes.EpochChain
-
- start() - Method in class kafka.restore.rest.RestoreRestServer
-
Bind the RestServer to the provided port.
- START - Static variable in class kafka.restore.statemachine.api.State
-
- start() - Method in class kafka.tier.topic.TierTopicConsumer
-
- START_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- START_OFFSET_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- START_OFFSET_PARAM_NAME - Static variable in class kafka.restore.schedulers.Constants
-
- startBackupObjectsMetadata(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- startBlobMetadata(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- startBlobsVector(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- startCheckedFileIOHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
-
- startCompactionCommitAndSwap(FlatBufferBuilder) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- startDatabase(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.Database
-
- startDatabase(FlatBufferBuilder) - Static method in class kafka.durability.restore.db.serdes.Database
-
- startDatedList(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.DatedList
-
- startDeletePartition(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeletePartition
-
- startDeleteRecords(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- startDestinationObjectIdsVector(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- startDurabilityPartitionsOffsetsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Header
-
- startEpochChainVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- startEpochChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.EpochChange
-
- startEventKey(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.EventKey
-
- startHeader(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- startHeader(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.Header
-
- startHeader(FlatBufferBuilder) - Static method in class kafka.durability.restore.db.serdes.Header
-
- startHealthCheck(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.HealthCheck
-
- STARTING - Static variable in class kafka.common.EvenClusterLoadStatusDescriptionInternal
-
- startInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
-
- startIsrExpand(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.IsrExpand
-
- startIsrVector(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.DeleteRecords
-
- startIsrVector(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EpochChange
-
- startIsrVector(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- startIsrVector(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- startJob(FlatBufferBuilder) - Static method in class kafka.durability.restore.db.serdes.Job
-
- startJobsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Database
-
- startLatestDataFilesVector(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- startLifecycleManagerState(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- startMaterializationTrackingInfo(FlatBufferBuilder) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- startOffset() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- startOffset() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- startOffset() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- startOffset() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- startOffset() - Method in class kafka.tier.state.FileTierPartitionState
-
- startOffset() - Method in class kafka.tier.state.Header
-
- startOffset() - Method in interface kafka.tier.state.TierPartitionState
-
Determine start offset spanned by the TierPartitionState.
- startOffset - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- startOffsetChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.OffsetChange
-
- StartOffsetChange - Class in kafka.durability.events.serdes
-
- StartOffsetChange() - Constructor for class kafka.durability.events.serdes.StartOffsetChange
-
- startPartitionDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
-
- startPartitionDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- startPartitionDeletePreInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- startPartitionFence(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionFence
-
- startPartitionForceRestore(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionForceRestore
-
- startPartitionInfo(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.PartitionInfo
-
- startPartitionRestoreContext(FlatBufferBuilder) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- startPartitionRestoreContextsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.Job
-
- startPartitionsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- startPartitionUnfreezeLogStartOffset(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- startReplicasVector(FlatBufferBuilder, int) - Static method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- startRetentionChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.RetentionChange
-
- startRetentionDataVector(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- startSegmentDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
-
- startSegmentDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- startSegmentUploadComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadComplete
-
- startSegmentUploadInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
-
- startSourceObjectIdsVector(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- startStartOffsetChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.StartOffsetChange
-
- startTierKafkaKey(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierKafkaKey
-
- startTierOffsetsVector(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- startTierPartitionStateEntry(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
-
- startTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
-
- startTime() - Method in class kafka.durability.restore.db.serdes.Job
-
- startTime - Variable in class kafka.restore.db.Job
-
- StartToFenceEventSentTransition - Class in kafka.restore.statemachine.transitions
-
- StartToFenceEventSentTransition(MessageEmitter) - Constructor for class kafka.restore.statemachine.transitions.StartToFenceEventSentTransition
-
- startTopicInfo(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.TopicInfo
-
- startTopicMetadata(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- startTopicRetentionData(FlatBufferBuilder) - Static method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- startTopicsVector(FlatBufferBuilder, int) - Static method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- startTopicsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
-
- startUp() - Method in class kafka.restore.RestoreOrchestrator
-
Start up Async Service Schedulers and the dedicated thread to listen to response queue.
- startUp() - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Starts up the asynchronous service scheduler, so that it is ready to consume and process requests.
- startUp() - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
Starts up the AsyncTaskScheduler, so it is ready to consume and process requests.
- startUp() - Method in interface kafka.restore.schedulers.KafkaConnectionPool
-
Starts up Kafka connection pool.
- startUp() - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Provisions necessary resources for running KafkaConnectionPool.
- startUp() - Method in class kafka.restore.schedulers.KafkaManager
-
Starts up the KafkaManager, so it is ready to consume and process requests.
- startUp() - Method in class kafka.restore.schedulers.ObjectStoreManager
-
Starts up the ObjectStoreManager, so it is ready to consume and process requests.
- startUp() - Method in interface kafka.restore.schedulers.ObjectStorePool
-
Starts up ObjectStorePool.
- startUp() - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
Starts up the ObjectStorePool.
- startUp() - Method in class kafka.restore.schedulers.S3ObjectStorePool
-
- startup() - Method in class kafka.tier.topic.TierTopicManager
-
- state() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- state - Variable in class kafka.restore.db.PartitionRestoreContext
-
- State - Class in kafka.restore.statemachine.api
-
- State(String) - Constructor for class kafka.restore.statemachine.api.State
-
- state() - Method in class kafka.tier.domain.AbstractTierSegmentMetadata
-
The current state of the segment.
- state() - Method in class kafka.tier.domain.TierObjectMetadata
-
- state() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- state() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- state() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- state() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- state() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- state() - Method in class kafka.tier.state.SegmentState
-
- stateFileChannel() - Method in class kafka.restore.operators.FtpsSegmentView
-
- stateMachineController() - Method in class kafka.restore.RestoreOrchestrator
-
- StateMachineController - Class in kafka.restore.statemachine
-
Each partition to be restored corresponding to one PartitionStateMachine, StateMachineController controls
their state transition in their state machine, and updates their state in RestoreDB accordingly.
- StateMachineController(Job, MessageEmitter) - Constructor for class kafka.restore.statemachine.StateMachineController
-
- StateManager - Class in kafka.tier.backupObjectLifecycle
-
This class is responsible for handling the state information required for LifecycleManager.
- StateManager() - Constructor for class kafka.tier.backupObjectLifecycle.StateManager
-
- StateManager.LifecycleManagerVersionException - Exception in kafka.tier.backupObjectLifecycle
-
- StateManagerConfig - Class in kafka.tier.backupObjectLifecycle
-
- StateManagerConfig(TierObjectStore, String) - Constructor for class kafka.tier.backupObjectLifecycle.StateManagerConfig
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.AbstractTierMetadata
-
The lastMaterializedOffsetAndEpoch for the tier partition state at the time this metadata was generated.
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionFence
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.PartitionForceRestore
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- stateOffsetAndEpoch() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- stateOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- states() - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
Return FSM registered states.
- states() - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- status() - Method in class kafka.durability.restore.db.serdes.Job
-
- status() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- status - Variable in class kafka.restore.db.Job
-
- status - Variable in class kafka.restore.db.PartitionRestoreContext
-
- status() - Method in class kafka.restore.statemachine.StateMachineController
-
- status() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- status() - Method in class kafka.tier.state.FileTierPartitionState
-
- status() - Method in class kafka.tier.state.Header
-
- status() - Method in interface kafka.tier.state.TierPartitionState
-
Return the current status of the TierPartitionState.
- status() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
Retrieve status of tiered partition.
- StatusResponse - Class in kafka.restore.rest
-
- StatusResponse(int, String, int, int, int, int) - Constructor for class kafka.restore.rest.StatusResponse
-
- stop() - Method in class kafka.restore.rest.RestoreRestServer
-
- StreamsResetter - Class in kafka.tools
-
StreamsResetter
resets the processing state of a Kafka Streams application so that, for example,
you can reprocess its input from scratch.
- StreamsResetter() - Constructor for class kafka.tools.StreamsResetter
-
- subContext() - Method in class kafka.tier.fetcher.CancellationContext
-
Create a new child CancellationContext.
- submitFetchFtpsRequest(KafkaFetchFtpsRequest) - Method in class kafka.restore.schedulers.DryrunKafkaConnectionPoolImpl
-
- submitFetchFtpsRequest(KafkaFetchFtpsRequest) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- submitKafkaEventRequest(KafkaRequest) - Method in class kafka.restore.schedulers.DryrunKafkaConnectionPoolImpl
-
- submitKafkaEventRequest(KafkaRequest) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- submitKafkaRequest(KafkaRequest) - Method in interface kafka.restore.schedulers.KafkaConnectionPool
-
Submits KafkaRequest to be scheduled.
- submitKafkaRequest(KafkaRequest) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Submits KafkaRequest to be scheduled.
- submitKafkaValidateLogRangeRequest(KafkaValidateLogRangeRequest) - Method in class kafka.restore.schedulers.DryrunKafkaConnectionPoolImpl
-
- submitKafkaValidateLogRangeRequest(KafkaValidateLogRangeRequest) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
- submitObjectStoreRequest(ObjectStoreRequest) - Method in interface kafka.restore.schedulers.ObjectStorePool
-
Submits ObjectStoreRequest to be scheduled.
- submitObjectStoreRequest(ObjectStoreRequest) - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
Submits objectStoreRequest to be processed.
- submitObjectStoreRequest(ObjectStoreRequest) - Method in class kafka.restore.schedulers.S3ObjectStorePool
-
- submitRequest(MessageRequest) - Method in interface kafka.restore.MessageEmitter
-
- submitRequest(MessageRequest) - Method in class kafka.restore.RestoreOrchestrator
-
Submit the request to corresponding Async Service Scheduler
If the request queue of the Scheduler is full, the request will be put into RestoreOrchestrator's
response queue, which is essentially be treated as a retry.
- submitRequest(MessageRequest) - Method in class kafka.restore.schedulers.AbstractAsyncServiceScheduler
-
Submits a request to the request queue.
- submitRequest(MessageRequest) - Method in class kafka.restore.schedulers.AsyncTaskScheduler
-
- submitRequest(MessageRequest) - Method in class kafka.restore.schedulers.KafkaManager
-
- submitRequest(MessageRequest) - Method in class kafka.restore.schedulers.ObjectStoreManager
-
- submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest) - Method in class kafka.restore.schedulers.DryrunObjectStorePoolImpl
-
- submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest) - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
- submitTierPartitionStatusRequest(KafkaTierPartitionStatusRequest) - Method in class kafka.restore.schedulers.DryrunKafkaConnectionPoolImpl
-
- submitTierPartitionStatusRequest(KafkaTierPartitionStatusRequest) - Method in class kafka.restore.schedulers.KafkaConnectionPoolImpl
-
Submits a KafkaTierPartitionStatusRequest to be scheduled.
- submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest) - Method in class kafka.restore.schedulers.DryrunObjectStorePoolImpl
-
- submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest) - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
- subscription() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- suffix() - Method in enum kafka.tier.store.TierObjectStore.FileType
-
- suffix - Variable in enum kafka.utils.checksum.Algorithm
-
- SUPER_BLOCK_LENGTH_ADLER - Static variable in class kafka.tier.state.FileTierPartitionState
-
- SUPER_BLOCK_LENGTH_NO_CHECKSUM - Static variable in class kafka.tier.state.FileTierPartitionState
-
- takePositionsSnapshot() - Method in class kafka.tier.TierTopicManagerCommitter
-
Take a snapshot of the current positions for all Tier Topic partitions.
- TENANT_PREFIX_REGEX - Static variable in class kafka.common.TenantHelpers
-
- TenantHelpers - Class in kafka.common
-
- TenantHelpers() - Constructor for class kafka.common.TenantHelpers
-
- threadPool() - Method in class kafka.restore.schedulers.ObjectStorePoolImpl
-
- ThreadPoolMonitor - Class in kafka.restore.schedulers
-
- ThreadPoolMonitor(String, ThreadPoolExecutor, int) - Constructor for class kafka.restore.schedulers.ThreadPoolMonitor
-
- throttled() - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- throwOnCondition - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- TIER_COMPACT_ENABLED - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_COMPACT_ENABLED_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_PARTITION_STATUS_URI_PATH - Static variable in class kafka.restore.schedulers.Constants
-
- TIER_PROPERTIES_CONFIG_FILE - Static variable in class kafka.tier.tools.RecoveryUtils
-
- TIER_PROPERTIES_CONFIG_FILE_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- TIER_STATE_TOPIC_PARTITION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STATE_TOPIC_PARTITION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_OFFSET_VALIDATION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_OFFSET_VALIDATION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_VALIDATION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_VALIDATION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierAbortedTxnReader - Class in kafka.tier.fetcher
-
- TierAbortedTxnReader() - Constructor for class kafka.tier.fetcher.TierAbortedTxnReader
-
- TierCompactionCommitAndSwap - Class in kafka.tier.domain
-
CompactionCommitAndSwap domain object.
- TierCompactionCommitAndSwap(TopicIdPartition, int, OffsetAndEpoch, UUID, Set<UUID>, Set<UUID>, long, CompactStats) - Constructor for class kafka.tier.domain.TierCompactionCommitAndSwap
-
- TierCompactionCommitAndSwap(TopicIdPartition, int, UUID, UUID, OffsetAndEpoch, Set<UUID>, long, CompactStats) - Constructor for class kafka.tier.domain.TierCompactionCommitAndSwap
-
- TierCompactionCommitAndSwap(TierSegmentUploadInitiate, UUID, Set<UUID>, long, CompactStats) - Constructor for class kafka.tier.domain.TierCompactionCommitAndSwap
-
- TierCompactionCommitAndSwap(TopicIdPartition, CompactionCommitAndSwap) - Constructor for class kafka.tier.domain.TierCompactionCommitAndSwap
-
- tierEpoch() - Method in class kafka.tier.domain.AbstractTierMetadata
-
tierEpoch for the tier metadata
- tierEpoch() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- tierEpoch() - Method in class kafka.tier.domain.TierObjectMetadata
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionFence
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- tierEpoch() - Method in class kafka.tier.serdes.InitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- tierEpoch() - Method in class kafka.tier.state.FileTierPartitionState
-
- tierEpoch() - Method in class kafka.tier.state.Header
-
- tierEpoch() - Method in class kafka.tier.state.SegmentState
-
- tierEpoch() - Method in interface kafka.tier.state.TierPartitionState
-
Return the current tierEpoch.
- tierEpoch() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- TierFetcher - Class in kafka.tier.fetcher
-
- TierFetcher(Time, TierFetcherConfig, TierObjectStore, KafkaScheduler, Metrics, LogContext) - Constructor for class kafka.tier.fetcher.TierFetcher
-
- TierFetcherConfig - Class in kafka.tier.fetcher
-
- TierFetcherConfig(KafkaConfig) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig(int, int, int, int, Long) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig() - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- tierFetcherMetrics - Variable in class kafka.tier.fetcher.TierFetcher
-
- TierFetchResult - Class in kafka.tier.fetcher
-
- TierFetchResult(ReclaimableMemoryRecords, List<AbortedTxn>, Throwable) - Constructor for class kafka.tier.fetcher.TierFetchResult
-
- TierKafkaKey - Class in kafka.tier.serdes
-
- TierKafkaKey() - Constructor for class kafka.tier.serdes.TierKafkaKey
-
- tierLogSegmentForOffset(TierPartitionState, long) - Static method in class kafka.tier.state.TierUtils
-
- TierMessageFormatter - Class in kafka.tier.topic
-
- TierMessageFormatter() - Constructor for class kafka.tier.topic.TierMessageFormatter
-
- TierMetadataComparator - Class in kafka.tier.tools
-
This tool will act as the downstream of the fencing tool in the recovery workflow
Once the fenced tier topic details are available as input, this tool will do the following:
1.
- TierMetadataComparator(Time, Properties, List<FenceEventInfo>, Path, Scheduler) - Constructor for class kafka.tier.tools.TierMetadataComparator
-
- TierMetadataDebugger - Class in kafka.tier.tools
-
TierMetadataDebugger is a tool to dump raw metadata events of TierTopicPartitions, additionally it can also materialize and
generate expected state.
- TierMetadataDebugger() - Constructor for class kafka.tier.tools.TierMetadataDebugger
-
- TierMetadataDeserializationException - Exception in kafka.tier.exceptions
-
TierMetadataDeserializationException
is an exception for cases where metadata
belonging to the tier topic cannot be deserialized.
- TierMetadataDeserializationException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataFatalException - Exception in kafka.tier.exceptions
-
- TierMetadataFatalException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- tierMetadataMaxPollMs - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- tierMetadataNumPartitions - Variable in class kafka.tier.backupObjectLifecycle.LifecycleManagerConfig
-
- TierMetadataRetriableException - Exception in kafka.tier.exceptions
-
- TierMetadataRetriableException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataValidator - Class in kafka.tier.tools
-
TierMetadataValidator: Tool to validate the materialization of the tier topic partition's materialization states.
- TierMetadataValidator.OffsetValidationResult - Class in kafka.tier.tools
-
- tierNamespace - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- TierObjectMetadata - Class in kafka.tier.domain
-
- TierObjectMetadata(TopicIdPartition, TierPartitionStateEntry) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TopicIdPartition, int, UUID, long, long, long, long, int, TierObjectMetadata.State, boolean, boolean, boolean, TierUploadType, TierObjectStore.OpaqueData, boolean) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TierSegmentUploadInitiate, boolean) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata.State - Enum in kafka.tier.domain
-
- TierObjectStore - Interface in kafka.tier.store
-
- TierObjectStore.Backend - Enum in kafka.tier.store
-
- TierObjectStore.BackupObjectsListMetadata - Class in kafka.tier.store
-
Metadata for the list of the backed up objects.
- TierObjectStore.DataTypePathPrefix - Enum in kafka.tier.store
-
- TierObjectStore.FileType - Enum in kafka.tier.store
-
- TierObjectStore.KeyAndVersion - Class in kafka.tier.store
-
- TierObjectStore.LifecycleManagerStateMetadata - Class in kafka.tier.store
-
Metadata for the state of the backed up object Lifecycle Manager.
- TierObjectStore.ObjectMetadata - Class in kafka.tier.store
-
- TierObjectStore.ObjectStoreMetadata - Interface in kafka.tier.store
-
- TierObjectStore.OpaqueData - Class in kafka.tier.store
-
- TierObjectStore.TierStateRestoreSnapshotMetadata - Class in kafka.tier.store
-
- TierObjectStoreConfig - Class in kafka.tier.store
-
- TierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreConfig(Optional<String>, Optional<Integer>) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreConfig(String, Integer) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreFactory - Class in kafka.tier.tools
-
This class will act as the factory for generating and maintaining the instance map for the various kinds
of the object store backends.
- TierObjectStoreFactory() - Constructor for class kafka.tier.tools.TierObjectStoreFactory
-
- TierObjectStoreFatalException - Exception in kafka.tier.exceptions
-
- TierObjectStoreFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreFatalException(String) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreMetrics - Class in kafka.tier.store
-
- TierObjectStoreMetricsEnabled - Class in kafka.tier.store
-
- TierObjectStoreMetricsEnabled(TierObjectStore, Metrics, Time) - Constructor for class kafka.tier.store.TierObjectStoreMetricsEnabled
-
- TierObjectStoreResponse - Interface in kafka.tier.store
-
- TierObjectStoreRetriableException - Exception in kafka.tier.exceptions
-
- TierObjectStoreRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
-
- TierObjectStoreRetriableException(String) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
-
- TierObjectStoreUtils - Class in kafka.tier.store
-
- TierObjectStoreUtils() - Constructor for class kafka.tier.store.TierObjectStoreUtils
-
- tierOffsets(int) - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- tierOffsetsAsByteBuffer() - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- tierOffsetsInByteBuffer(ByteBuffer) - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- tierOffsetsLength() - Method in class kafka.backupRestore.objectLifecycle.serdes.LifecycleManagerState
-
- TierPartitionDeleteComplete - Class in kafka.tier.domain
-
Partition delete complete metadata.
- TierPartitionDeleteComplete(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteComplete(TopicIdPartition, PartitionDeleteComplete) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteInitiate - Class in kafka.tier.domain
-
Partition delete initiate metadata.
- TierPartitionDeleteInitiate(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionDeleteInitiate(TopicIdPartition, PartitionDeleteInitiate) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionDeletePreInitiate - Class in kafka.tier.domain
-
Partition delete pre-initiate metadata.
- TierPartitionDeletePreInitiate(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- TierPartitionDeletePreInitiate(TopicIdPartition, PartitionDeletePreInitiate) - Constructor for class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- TierPartitionFence - Class in kafka.tier.domain
-
- TierPartitionFence(TopicIdPartition, UUID, boolean) - Constructor for class kafka.tier.domain.TierPartitionFence
-
- TierPartitionFence(TopicIdPartition, PartitionFence) - Constructor for class kafka.tier.domain.TierPartitionFence
-
- TierPartitionForceRestore - Class in kafka.tier.domain
-
- TierPartitionForceRestore(TopicIdPartition, UUID, long, long, OffsetAndEpoch, String, Boolean) - Constructor for class kafka.tier.domain.TierPartitionForceRestore
-
- TierPartitionForceRestore(TopicIdPartition, PartitionForceRestore) - Constructor for class kafka.tier.domain.TierPartitionForceRestore
-
- TierPartitionState - Interface in kafka.tier.state
-
- TierPartitionState.AppendResult - Enum in kafka.tier.state
-
The result of an attempt to append a tier metadata entry.
- TierPartitionState.RecoveryOperation - Enum in kafka.tier.state
-
Various operations required while recovering a tiered partition from data loss
- TierPartitionState.RestoreResult - Enum in kafka.tier.state
-
The result of an attempt to restore a TierPartitionState via a PartitionForceRestore event
- TierPartitionStateEntry - Class in kafka.tier.serdes
-
- TierPartitionStateEntry() - Constructor for class kafka.tier.serdes.TierPartitionStateEntry
-
- TierPartitionStateFactory - Class in kafka.tier.state
-
- TierPartitionStateFactory(boolean, boolean, boolean) - Constructor for class kafka.tier.state.TierPartitionStateFactory
-
- TierPartitionStateFencingTrigger - Class in kafka.tier.tools
-
A tool that injects PartitionFence events into TierTopic for a provided list of
TopicIdPartition.
- TierPartitionStateFencingTrigger() - Constructor for class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- TierPartitionStateHeader - Class in kafka.tier.serdes
-
- TierPartitionStateHeader() - Constructor for class kafka.tier.serdes.TierPartitionStateHeader
-
- TierPartitionStateIllegalListenerException - Exception in kafka.tier.exceptions
-
- TierPartitionStateIllegalListenerException(String) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateRestoreTrigger - Class in kafka.tier.tools
-
A tool that injects PartitionForceRestore events into TierTopic for a provided list of
TopicIdPartition.
- TierPartitionStateRestoreTrigger() - Constructor for class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- TierPartitionStatus - Enum in kafka.tier.state
-
- TierPartitionUnfreezeLogStartOffset - Class in kafka.tier.domain
-
- TierPartitionUnfreezeLogStartOffset(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- TierPartitionUnfreezeLogStartOffset(TopicIdPartition, PartitionUnfreezeLogStartOffset) - Constructor for class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- TierPartitionUnfreezeLogStartOffsetTrigger - Class in kafka.tier.tools
-
- TierPartitionUnfreezeLogStartOffsetTrigger() - Constructor for class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
-
- TierRecordType - Enum in kafka.tier.domain
-
- TierRecoveryConfig - Class in kafka.tier.tools
-
- TierRecoveryConfig() - Constructor for class kafka.tier.tools.TierRecoveryConfig
-
- TierReplicaManager - Class in kafka.tier
-
Replica manager for tiered storage.
- TierReplicaManager() - Constructor for class kafka.tier.TierReplicaManager
-
- TierReplicaManager.ChangeListener - Interface in kafka.tier
-
Interface to register callbacks on the lifecycle of tiering enabled topic partitions.
- TierSegmentDeleteComplete - Class in kafka.tier.domain
-
Delete complete metadata.
- TierSegmentDeleteComplete(TopicIdPartition, int, UUID, Optional<OffsetAndEpoch>) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteComplete(TopicIdPartition, SegmentDeleteComplete) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteComplete(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteInitiate - Class in kafka.tier.domain
-
Segment delete initiate metadata.
- TierSegmentDeleteInitiate(TopicIdPartition, int, UUID, Optional<OffsetAndEpoch>) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentDeleteInitiate(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentDeleteInitiate(TopicIdPartition, SegmentDeleteInitiate) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentReader - Class in kafka.tier.fetcher
-
- TierSegmentReader(String) - Constructor for class kafka.tier.fetcher.TierSegmentReader
-
- TierSegmentReader.NextOffsetAndBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentReader.RecordsAndNextBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentUploadComplete - Class in kafka.tier.domain
-
Upload complete metadata.
- TierSegmentUploadComplete(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TierSegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TopicIdPartition, SegmentUploadComplete) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadInitiate - Class in kafka.tier.domain
-
Upload initiate metadata.
- TierSegmentUploadInitiate(TopicIdPartition, int, UUID, long, long, long, long, int, boolean, boolean, boolean, TierUploadType, OffsetAndEpoch, TierObjectStore.OpaqueData) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierSegmentUploadInitiate(TopicIdPartition, int, UUID, Optional<UUID>, long, long, long, long, int, boolean, boolean, boolean, TierUploadType, OffsetAndEpoch, TierObjectStore.OpaqueData) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierSegmentUploadInitiate(TopicIdPartition, SegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- tierStateFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- TierStateFetcher - Class in kafka.tier.fetcher
-
- TierStateFetcher(Integer, TierObjectStore) - Constructor for class kafka.tier.fetcher.TierStateFetcher
-
- tierStateFile() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- TierStateRestoreSnapshotMetadata(TopicIdPartition, long, long, String) - Constructor for class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- TierStateRestoreSnapshotMetadata(TierPartitionForceRestore) - Constructor for class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- tierTimestampAndOffsets() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
TierTimestampAndOffsets that will be resolved by this fetch
- TierTopic - Class in kafka.tier.topic
-
- TierTopic(String) - Constructor for class kafka.tier.topic.TierTopic
-
- TierTopicAppender - Interface in kafka.tier.topic
-
TierTopicAppender allows interaction with a TierTopic.
- TierTopicClient - Class in kafka.tier.client
-
- TierTopicClient() - Constructor for class kafka.tier.client.TierTopicClient
-
- TierTopicConsumer - Class in kafka.tier.topic
-
Tier topic consumer.
- TierTopicConsumer(TierTopicManagerConfig, LogDirFailureChannel, TierStateFetcher, Metrics, Time) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer(TierTopicManagerConfig, Supplier<Consumer<byte[], byte[]>>, Supplier<Consumer<byte[], byte[]>>, TierTopicManagerCommitter, TierStateFetcher, Optional<Metrics>, Time) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer.ClientCtx - Interface in kafka.tier.topic
-
- TierTopicConsumerSupplier - Class in kafka.tier.client
-
- TierTopicConsumerSupplier(TierTopicManagerConfig, String) - Constructor for class kafka.tier.client.TierTopicConsumerSupplier
-
- TierTopicIncorrectPartitionCountException - Exception in kafka.tier.exceptions
-
- TierTopicIncorrectPartitionCountException(String) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicInitLeader - Class in kafka.tier.domain
-
Init leader metadata.
- TierTopicInitLeader(TopicIdPartition, int, UUID, int, Optional<OffsetAndEpoch>) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicInitLeader(TopicIdPartition, int, UUID, int) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicInitLeader(TopicIdPartition, InitLeader) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicManager - Class in kafka.tier.topic
-
A metadata store for tiered storage.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<Producer<byte[], byte[]>>, Supplier<InternalAdmin>) - Constructor for class kafka.tier.topic.TierTopicManager
-
Instantiate TierTopicManager.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<InternalAdmin>, Time) - Constructor for class kafka.tier.topic.TierTopicManager
-
Primary public constructor for TierTopicManager.
- TierTopicManagerCommitter - Class in kafka.tier
-
- TierTopicManagerCommitter(TierTopicManagerConfig, LogDirFailureChannel) - Constructor for class kafka.tier.TierTopicManagerCommitter
-
Instantiate a TierTopicManagerCommitter
- TierTopicManagerConfig - Class in kafka.tier.topic
-
- TierTopicManagerConfig(Supplier<Map<String, Object>>, String, short, short, int, String, Long, Integer, Integer, List<String>) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicManagerConfig(KafkaConfig, Supplier<Map<String, Object>>, String) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicMaterializationToolConfig - Class in kafka.tier.tools
-
- TierTopicMaterializationToolConfig(Properties) - Constructor for class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierTopicMaterializationUtils - Class in kafka.tier.tools
-
TierTopicMaterializationUtils provides utils for dumping materialization events from tier topic for the given source
topic(or all) for a give source partition(or all).
- TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, Properties, Map<TopicIdPartition, Long>, Scheduler) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
-
- TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, Properties, Scheduler) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
-
- TierTopicPartitioner - Class in kafka.tier.topic
-
- TierTopicPartitioner(int) - Constructor for class kafka.tier.topic.TierTopicPartitioner
-
- TierTopicProducerSupplier - Class in kafka.tier.client
-
- TierTopicProducerSupplier(TierTopicManagerConfig, Time) - Constructor for class kafka.tier.client.TierTopicProducerSupplier
-
- TierTopicReader - Class in kafka.tier.backupObjectLifecycle
-
Instances of this class are used to consume the tier state topic and extract information about segments that have been
deleted by Kafka.
- TierTopicReader(TierTopicReaderConfig) - Constructor for class kafka.tier.backupObjectLifecycle.TierTopicReader
-
- TierUploadType - Enum in kafka.tier.domain
-
- TierUtils - Class in kafka.tier.state
-
- TierUtils() - Constructor for class kafka.tier.state.TierUtils
-
- timeForDeletionInMs() - Method in class kafka.backupRestore.objectLifecycle.serdes.BlobMetadata
-
- timeMs() - Method in class kafka.durability.events.serdes.RetentionChange
-
- timeStamp() - Method in class kafka.durability.events.serdes.HealthCheck
-
- timestamp - Variable in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- timestampIndexFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- timeStampRestoreFrom - Variable in class kafka.restore.db.PartitionRestoreContext
-
- toArray(InputStream) - Static method in class kafka.tier.fetcher.TierStateFetcher
-
Read the input stream from its current position to its limit into a byte array.
- toByte(TierRecordType) - Static method in enum kafka.tier.domain.TierRecordType
-
- toByte(TierUploadType) - Static method in enum kafka.tier.domain.TierUploadType
-
- toByte(TierPartitionStatus) - Static method in enum kafka.tier.state.TierPartitionStatus
-
- toJson() - Method in class kafka.common.TopicPlacement
-
Serialize this object back to json string.
- toJson() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- toJson() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- toJson() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- toOldStatus(BrokerShutdownStatus) - Static method in enum kafka.common.BrokerShutdownStatusV1
-
Convert the new #BrokerShutdownStatus
to this
deprecated status.
- toOldStatus(PartitionReassignmentsStatus) - Static method in enum kafka.common.PartitionReassignmentsStatusV1
-
Convert the new #PartitionReassignmentsStatus
to this
deprecated status.
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.LifecycleManagerStateMetadata
-
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- toPath(String, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore.ObjectStoreMetadata
-
Converts the ObjectStoreMetadata to an object store key path, taking into account a
given key prefix and file type
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- topic() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
The name of the topic.
- topic() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- topic() - Method in class kafka.durability.db.serdes.TopicInfo
-
- topic() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- topic() - Method in class kafka.internals.generated.OffsetCommitKey
-
- topic() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- topic - Variable in class kafka.restore.db.PartitionRestoreContext
-
- TOPIC - Static variable in class kafka.restore.statemachine.Constants
-
- topic - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- topic() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- topic() - Method in class kafka.tier.TopicIdPartition
-
- TOPIC_CONFIG - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- TOPIC_DOC - Static variable in class kafka.durability.tools.DumpDurabilityDb
-
- TOPIC_PARAM_NAME - Static variable in class kafka.restore.schedulers.Constants
-
Parameter names for the Kafka API.
- topicAsByteBuffer() - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- topicAsByteBuffer() - Method in class kafka.durability.db.serdes.TopicInfo
-
- topicAsByteBuffer() - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- TopicConfig - Class in kafka.restore.configmap
-
- TopicConfig() - Constructor for class kafka.restore.configmap.TopicConfig
-
- TopicConfig(String, long) - Constructor for class kafka.restore.configmap.TopicConfig
-
- topicConfig() - Static method in class kafka.tier.topic.TierTopic
-
- topicId() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- topicId() - Method in class kafka.durability.events.serdes.EventKey
-
- topicId() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId() - Method in class kafka.tier.state.Header
-
- topicId() - Method in class kafka.tier.TopicIdPartition
-
- topicIdAsBase64() - Method in class kafka.tier.TopicIdPartition
-
- topicIdAsByteBuffer() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- topicIdAsByteBuffer() - Method in class kafka.durability.events.serdes.EventKey
-
- topicIdBase64 - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- topicIdBase64() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- topicIdInByteBuffer(ByteBuffer) - Method in class kafka.durability.db.serdes.PartitionInfo
-
- topicIdInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.EventKey
-
- topicIdPartition() - Method in class kafka.restore.operators.FtpsSegmentView
-
- topicIdPartition() - Method in class kafka.tier.domain.AbstractTierMetadata
-
Topic-partition corresponding to this tier metadata.
- topicIdPartition() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- topicIdPartition() - Method in class kafka.tier.domain.TierObjectMetadata
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionFence
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- topicIdPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicIdPartition() - Method in interface kafka.tier.state.TierPartitionState
-
Optional TopicIdPartition corresponding to this TierPartition
If one has not been set, returns empty
- topicIdPartition() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- topicIdPartition() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- topicIdPartition() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- TopicIdPartition - Class in kafka.tier
-
- TopicIdPartition(String, UUID, int) - Constructor for class kafka.tier.TopicIdPartition
-
- topicInByteBuffer(ByteBuffer) - Method in class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- topicInByteBuffer(ByteBuffer) - Method in class kafka.durability.db.serdes.TopicInfo
-
- topicInByteBuffer(ByteBuffer) - Method in class kafka.durability.restore.db.serdes.PartitionRestoreContext
-
- TopicInfo - Class in kafka.durability.db.serdes
-
- TopicInfo() - Constructor for class kafka.durability.db.serdes.TopicInfo
-
- TopicMetadata - Class in kafka.backupRestore.objectLifecycle.serdes
-
- TopicMetadata() - Constructor for class kafka.backupRestore.objectLifecycle.serdes.TopicMetadata
-
- topicName() - Method in class kafka.durability.events.serdes.EventKey
-
- topicName() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicName() - Method in interface kafka.tier.topic.InitializedTierTopic
-
- topicName() - Method in class kafka.tier.topic.TierTopic
-
- topicName(String) - Static method in class kafka.tier.topic.TierTopic
-
- topicNameAsByteBuffer() - Method in class kafka.durability.events.serdes.EventKey
-
- topicNameAsByteBuffer() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicNameInByteBuffer(ByteBuffer) - Method in class kafka.durability.events.serdes.EventKey
-
- topicNameInByteBuffer(ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicPartition() - Method in interface kafka.tier.state.TierPartitionState
-
The topic-partition corresponding to this TierPartition.
- topicPartition() - Method in class kafka.tier.TopicIdPartition
-
- TopicPartitionConfigMapGenerator - Class in kafka.restore.configmap
-
This tool is for generating TopicPartition List for restoring.
- TopicPartitionConfigMapGenerator() - Constructor for class kafka.restore.configmap.TopicPartitionConfigMapGenerator
-
- TopicPlacement - Class in kafka.common
-
- TopicPlacement.ConstraintCount - Class in kafka.common
-
- TopicPlacement.ObserverPromotionPolicy - Enum in kafka.common
-
- TopicPlacement.Replica - Class in kafka.common
-
- TopicPlacement.TopicPlacementValidator - Class in kafka.common
-
- TopicReplicaAssignor - Interface in kafka.assignor
-
A interface for computing a replica assignment for a given topic.
- TopicReplicaAssignor.NewPartitions - Class in kafka.assignor
-
- TopicReplicaAssignorBuilder - Interface in kafka.assignor
-
- TopicRetentionData - Class in kafka.backupRestore.objectLifecycle.serdes
-
- TopicRetentionData() - Constructor for class kafka.backupRestore.objectLifecycle.serdes.TopicRetentionData
-
- topics(int) - Method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- topics(TopicMetadata, int) - Method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- topics(int) - Method in class kafka.durability.db.serdes.Database
-
- topics(TopicInfo, int) - Method in class kafka.durability.db.serdes.Database
-
- TOPICS - Static variable in class kafka.restore.schedulers.Constants
-
- topicsLength() - Method in class kafka.backupRestore.objectLifecycle.serdes.BackupObjectsMetadata
-
- topicsLength() - Method in class kafka.durability.db.serdes.Database
-
- toRawBytes() - Method in class kafka.tier.store.encryption.KeySha
-
- toSend() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- toState(byte) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
- toString() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
- toString() - Method in class kafka.common.AliveBrokersSnapshot
-
- toString() - Method in class kafka.common.BalancerStatusDescriptionInternal
-
- toString() - Method in class kafka.common.BrokerAdditionDescriptionInternal
-
- toString() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- toString() - Method in class kafka.common.BrokerRemovalRequest
-
- toString() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- toString() - Method in class kafka.common.TopicPlacement.Replica
-
- toString() - Method in class kafka.common.TopicPlacement
-
- toString() - Method in class kafka.internals.generated.ComputedQuotaKey.EntityData
-
- toString() - Method in class kafka.internals.generated.ComputedQuotaKey
-
- toString() - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedBrokerQuota
-
- toString() - Method in class kafka.internals.generated.ComputedQuotaValue.ComputedQuota
-
- toString() - Method in class kafka.internals.generated.ComputedQuotaValue
-
- toString() - Method in class kafka.internals.generated.GroupMetadataKey
-
- toString() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
-
- toString() - Method in class kafka.internals.generated.GroupMetadataValue
-
- toString() - Method in class kafka.internals.generated.OffsetCommitKey
-
- toString() - Method in class kafka.internals.generated.OffsetCommitValue
-
- toString() - Method in class kafka.internals.generated.TransactionLogKey
-
- toString() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
-
- toString() - Method in class kafka.internals.generated.TransactionLogValue
-
- toString() - Method in class kafka.restore.messages.KafkaRequest
-
- toString() - Method in class kafka.restore.messages.KafkaTierPartitionStatusRequest
-
- toString() - Method in class kafka.restore.messages.MessageResponse
-
- toString() - Method in class kafka.restore.operators.SegmentStateAndPath
-
- toString() - Method in class kafka.restore.statemachine.api.State
-
- toString() - Method in class kafka.restore.statemachine.events.KafkaRestoreEvent
-
- toString() - Method in class kafka.restore.statemachine.transitions.AbstractTransition
-
- toString() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- toString() - Method in class kafka.tier.domain.TierObjectMetadata
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- toString() - Method in class kafka.tier.domain.TierPartitionFence
-
- toString() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- toString() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- toString() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- toString() - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchKey
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- toString() - Method in class kafka.tier.fetcher.TierFetchResult
-
- toString() - Method in class kafka.tier.fetcher.TierSegmentReader.NextOffsetAndBatchMetadata
-
- toString() - Method in class kafka.tier.state.CompactStats
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.Initialization
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.LeaderEpoch
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState
-
- toString() - Method in class kafka.tier.state.Header
-
- toString() - Method in class kafka.tier.state.OffsetAndEpoch
-
- toString() - Method in class kafka.tier.state.SegmentState
-
- toString() - Method in class kafka.tier.store.encryption.CleartextDataKey
-
- toString() - Method in class kafka.tier.store.encryption.KeyContext
-
- toString() - Method in class kafka.tier.store.encryption.KeySha
-
- toString() - Method in class kafka.tier.store.TierObjectStore.BackupObjectsListMetadata
-
- toString() - Method in class kafka.tier.store.TierObjectStore.LifecycleManagerStateMetadata
-
- toString() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- toString() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
-
- toString() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- toString() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- toString() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- toString() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
-
- toString() - Method in class kafka.tier.TopicIdPartition
-
- toString() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- toString() - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
-
- toString() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- totalMessages() - Method in class kafka.durability.db.serdes.PartitionInfo
-
- totalPartitions() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
-
The total number of partitions for this topic post-creation.
- totalSize() - Method in class kafka.tier.state.FileTierPartitionState
-
- totalSize() - Method in interface kafka.tier.state.TierPartitionState
-
Sum the size of all segment spanned by this TierPartitionState.
- toTierTopicPartition(TopicIdPartition) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartition(TopicIdPartition) - Method in class kafka.tier.topic.TierTopic
-
- toTierTopicPartition(TopicIdPartition, String, TierTopicPartitioner) - Static method in class kafka.tier.topic.TierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in class kafka.tier.topic.TierTopic
-
Generate the tier topic partitions containing data for tiered partitions.
- toTierTopicPartitions(Collection<TopicIdPartition>, String, TierTopicPartitioner) - Static method in class kafka.tier.topic.TierTopic
-
- toType(byte) - Static method in enum kafka.tier.domain.TierRecordType
-
- trackMaterialization(AbstractTierMetadata, CompletableFuture<TierPartitionState.AppendResult>) - Method in class kafka.tier.topic.TierTopicConsumer
-
Track materialization of provided metadata.
- trackMetadataInitialization(int) - Method in class kafka.tier.state.FileTierPartitionState
-
Listen for the flushed materialization state to materialize up to or past the provided leader epoch.
- trackMetadataInitialization(int) - Method in interface kafka.tier.state.TierPartitionState
-
Tracks the completion of tier metadata initialization.
- transactionalId() - Method in class kafka.internals.generated.TransactionLogKey
-
- transactionIndexFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
-
- transactionLastUpdateTimestampMs() - Method in class kafka.internals.generated.TransactionLogValue
-
- TransactionLogKey - Class in kafka.internals.generated
-
- TransactionLogKey(Readable, short) - Constructor for class kafka.internals.generated.TransactionLogKey
-
- TransactionLogKey(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.TransactionLogKey
-
- TransactionLogKey() - Constructor for class kafka.internals.generated.TransactionLogKey
-
- TransactionLogValue - Class in kafka.internals.generated
-
- TransactionLogValue(Readable, short) - Constructor for class kafka.internals.generated.TransactionLogValue
-
- TransactionLogValue(Readable, short, MessageContext) - Constructor for class kafka.internals.generated.TransactionLogValue
-
- TransactionLogValue() - Constructor for class kafka.internals.generated.TransactionLogValue
-
- TransactionLogValue.PartitionsSchema - Class in kafka.internals.generated
-
- transactionPartitions() - Method in class kafka.internals.generated.TransactionLogValue
-
- transactionStartTimestampMs() - Method in class kafka.internals.generated.TransactionLogValue
-
- transactionStatus() - Method in class kafka.internals.generated.TransactionLogValue
-
- transactionTimeoutMs() - Method in class kafka.internals.generated.TransactionLogValue
-
- transferFrom(CheckedFileIO, long, long) - Method in class kafka.utils.checksum.CheckedFileIO
-
Transfer bytes to this file channel's from a readable byte channel's input relative position
- transferTo(long, long, CheckedFileIO) - Method in class kafka.utils.checksum.CheckedFileIO
-
Transfer bytes from this file channel's input relative position to a writable byte channel
- Transition<E extends Event> - Interface in kafka.restore.statemachine.api
-
- transitions() - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
Return FSM registered transitions.
- transitions() - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- transitToState(State) - Method in interface kafka.restore.statemachine.api.FiniteStateMachine
-
- transitToState(State) - Method in class kafka.restore.statemachine.RestoreFiniteStateMachine
-
- triggerEvenClusterLoadTask() - Method in interface kafka.controller.ClusterBalanceManager
-
Serves manual request to run a general rebalance on the cluster for the even cluster load
task.
- trimmedOffset() - Method in class kafka.durability.events.serdes.DeleteRecords
-
- truncate(long) - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- truncate(long) - Method in class kafka.utils.checksum.CheckedFileIO
-
Truncate file channel to given size based on relative position.
- truncate(long) - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- tryBecomeReady(boolean) - Method in class kafka.tier.topic.TierTopicManager
-
Try to move the TierTopicManager to ready state.
- tryExtendLease(long) - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
Attempts to extend the lease by amount additional bytes.
- tryLease(long) - Method in class kafka.tier.fetcher.MemoryTracker
-
Like newLease, this will attempt to create a new MemoryLease for the provided amount of
bytes.
- type() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- type() - Method in class kafka.tier.domain.TierCompactionCommitAndSwap
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierPartitionDeletePreInitiate
-
- type() - Method in class kafka.tier.domain.TierPartitionFence
-
- type() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- type() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- type() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- VALIDATE - Static variable in class kafka.tier.tools.TierRecoveryConfig
-
- validate() - Method in class kafka.utils.checksum.Adler32CheckedFileIO
-
- validate() - Method in class kafka.utils.checksum.CheckedFileIO
-
Validate compares with the value stored in header of the file with the checksum computed of the entire file.
- validate() - Method in class kafka.utils.checksum.NoChecksumFileIO
-
- VALIDATE_LOG_RANGE_URI_PATH - Static variable in class kafka.restore.schedulers.Constants
-
- validateAndGetS3RegionName(String) - Static method in class kafka.tier.store.S3TierObjectStore
-
- validateAssignment(TopicPlacement, List<TopicPlacement.Replica>, List<TopicPlacement.Replica>) - Static method in class kafka.common.TopicPlacement
-
Returns an error string if the sync and observer replica assignment doesn't match the constraints.
- validateChecksum() - Method in class kafka.tier.state.FileTierPartitionState
-
- validateChecksum() - Method in interface kafka.tier.state.TierPartitionState
-
Validates the integrity by computing the checksum and validating the checksum.
- validateLogRange() - Method in class kafka.restore.schedulers.PartitionLogRangeValidator
-
Send Kafka request to validate partition log range asynchronously.
- validatePartitions(Properties, Set<TopicPartition>) - Static method in class kafka.tier.tools.RecoveryUtils
-
- validateReconfiguration(Map<String, ?>) - Method in class kafka.metrics.KafkaYammerMetrics
-
- validateReconfiguration(KafkaConfig) - Method in class kafka.tier.backupObjectLifecycle.LifecycleManager
-
- validateReconfiguration(KafkaConfig) - Method in class kafka.tier.fetcher.TierFetcher
-
- validateStates(Path, Path, TopicPartition, long) - Method in class kafka.tier.tools.TierMetadataValidator
-
For the given 'expected' and 'actual' metadata states path, the method will validate if they
are same or not.
- validationSuccess() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- VALIDATOR - Static variable in class kafka.common.TopicPlacement
-
- validBytes() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- validPath(Algorithm, Path) - Static method in class kafka.utils.checksum.CheckedFileIO
-
getValidPath converts given input path based on the algorithm parameter to a valid algorithm specific path format
algo = ADLER
case-1a: path = somePath/tierMetadata -> somePath/tierMetadata.adler
case-1b: path = somePath/tierMetadata.adler -> somePath/tierMetadata.adler
algo = NO_CHECKSUM
case-2a: path = somePath/tierMetadata -> somePath/tierMetadata
case-2b: path = somePath/tierMetadata.adler -> somePath/tierMetadata
- valueOf(String) - Static method in enum kafka.common.BrokerShutdownStatusV1
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.common.PartitionReassignmentsStatusV1
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.common.TopicPlacement.ObserverPromotionPolicy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.db.Job.JobStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.db.PartitionRestoreContext.RestoreState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.db.PartitionRestoreContext.RestoreStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.messages.MessageResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.messages.MessageStatusCode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.OrchestratorStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.restore.schedulers.AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.domain.TierRecordType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.domain.TierUploadType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.RecoveryOperation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.RestoreResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.Backend
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.utils.checksum.Algorithm
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum kafka.common.BrokerShutdownStatusV1
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.common.PartitionReassignmentsStatusV1
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.common.TopicPlacement.ObserverPromotionPolicy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.db.Job.JobStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.db.PartitionRestoreContext.RestoreState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.db.PartitionRestoreContext.RestoreStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.messages.MessageResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.messages.MessageStatusCode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.OrchestratorStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.restore.schedulers.AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.domain.TierRecordType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.domain.TierUploadType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.RecoveryOperation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.RestoreResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.Backend
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.utils.checksum.Algorithm
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verifyObjectInBackend(TierObjectMetadata, long, TierObjectStore, boolean, CancellationContext, Function<TopicPartition, Long>) - Static method in class kafka.tier.tools.TierMetadataValidator
-
This method is a wrapper around the logic of verifying the segment files on S3 backend.
- verifyObjectNotLive(TierObjectStore, TopicIdPartition, UUID) - Static method in class kafka.tier.backupObjectLifecycle.ObjectStoreUtils
-
Verifies that the blobs uploaded under a given segment UUID are not live at the object store.
- verifyOnlyValidFileExists(Algorithm, Path) - Static method in class kafka.utils.checksum.CheckedFileIO
-
verifyOnlyValidFileExists is a helper util to check if the given input path is a valid ADLER or NO_CHECKSUM path.
- version() - Method in class kafka.backupRestore.objectLifecycle.serdes.Header
-
- version() - Method in class kafka.common.TopicPlacement
-
- version() - Method in class kafka.durability.db.serdes.Header
-
- version() - Method in class kafka.durability.events.serdes.BaseInfo
-
- version() - Method in class kafka.durability.restore.db.serdes.Header
-
- version - Variable in class kafka.restore.db.Job
-
- version() - Method in class kafka.tier.domain.TierObjectMetadata
-
- version() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- version() - Method in class kafka.tier.domain.TierPartitionUnfreezeLogStartOffset
-
- version() - Method in class kafka.tier.serdes.CheckedFileIOHeader
-
- version() - Method in class kafka.tier.serdes.CompactionCommitAndSwap
-
- version() - Method in class kafka.tier.serdes.InitLeader
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteComplete
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.PartitionDeletePreInitiate
-
- version() - Method in class kafka.tier.serdes.PartitionFence
-
- version() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- version() - Method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- version() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- version() - Method in class kafka.tier.state.Header
-
- version() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- VERSION_V1 - Static variable in class kafka.tier.domain.TierSegmentUploadComplete
-
- VERSION_V1 - Static variable in class kafka.tier.domain.TierSegmentUploadInitiate
-
- VERSION_V2 - Static variable in class kafka.tier.domain.TierSegmentUploadInitiate
-
- versionId() - Method in class kafka.tier.store.TierObjectStore.KeyAndVersion
-
- versionInByte() - Method in class kafka.tier.state.Header
-
- VersionInformation - Class in kafka.tier.store
-
- VersionInformation(String) - Constructor for class kafka.tier.store.VersionInformation
-