Skip navigation links
A B C D E F G H I J K L M N O P R S T U V W Z _ 

A

abortedTxns - Variable in class kafka.tier.fetcher.TierFetchResult
 
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
 
activeKeySha() - Method in class kafka.tier.store.encryption.EncryptionKeyManager
Returns the current active KeySha.
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
 
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
 
addContentHash(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
addControllerEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
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
 
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
 
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.durability.db.serdes.Database
 
addHighWatermark(FlatBufferBuilder, long) - Static method in class kafka.durability.db.serdes.PartitionInfo
 
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
 
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.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.PartitionFence
 
addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
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.
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
 
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.durability.db.serdes.PartitionInfo
 
addPartition(FlatBufferBuilder, int) - Static method in class kafka.durability.events.serdes.EventKey
 
addPartition(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
 
addPartitions(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.TopicInfo
 
addRestoreLogStartOffset(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
addRestoreOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
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.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
 
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
 
addState(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
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, byte) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
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
 
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.durability.db.serdes.TopicInfo
 
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.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
 
addVersion(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Header
 
addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
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.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>) - Constructor for class kafka.common.AliveBrokersSnapshot
 
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
 
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
 

B

balancerStatus() - Method in class kafka.common.BalancerStatusDescriptionInternal
 
BalancerStatusDescriptionInternal - Class in kafka.common
Class to store the status of the Confluent Balancer component.
BalancerStatusDescriptionInternal(BalancerStatus, Exception) - Constructor for class kafka.common.BalancerStatusDescriptionInternal
 
base64Encoded() - Method in class kafka.tier.store.encryption.CleartextDataKey
 
BaseInfo - Class in kafka.durability.events.serdes
 
BaseInfo() - Constructor for class kafka.durability.events.serdes.BaseInfo
 
baseOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
baseOffset() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
baseOffset() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
baseOffset() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
baseOffset() - Method in class kafka.tier.state.SegmentState
 
baseOffset() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
batches() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
batchIterator() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
becomeFollower(TierPartitionState) - Method in class kafka.tier.TierReplicaManager
Called when replica becomes follower.
becomeLeader(TierPartitionState, int) - Method in class kafka.tier.TierReplicaManager
Called when replica is elected to be the leader.
beginCatchup() - Method in class kafka.tier.state.FileTierPartitionState
 
beginCatchup() - Method in interface kafka.tier.state.TierPartitionState
Begin catchup phase for tier partition state.
beginCatchup() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Begin TierPartitionStatus.CATCHUP phase for this context.
bindHook(EncryptionKeyManager.WellKnownKeypathHook) - Method in class kafka.tier.store.encryption.EncryptionKeyManager
Bind a WellKnownKeypathHook instance to this EncryptionKeyManager.
BOOTSTRAP_SERVER_CONFIG - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
BOOTSTRAP_SERVER_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
BROKER_WORKDIR_LIST - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
BrokerAdditionDescriptionInternal - Class in kafka.common
Class to store the status of the broker addition operation's progress.
BrokerAdditionDescriptionInternal(int, PartitionReassignmentsStatus, BalancerOperationStatus, long, long, Exception) - Constructor for class kafka.common.BrokerAdditionDescriptionInternal
 
BrokerAddStatus - Class in kafka.common
Class to store status of broker add progress.
BrokerAddStatus(int, Exception) - Constructor for class kafka.common.BrokerAddStatus
 
brokerId() - Method in class kafka.common.BrokerAdditionDescriptionInternal
 
brokerId() - Method in class kafka.common.BrokerAddStatus
 
brokerId() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
brokerId() - Method in class kafka.durability.events.serdes.HealthCheck
 
brokerId() - Method in class kafka.tier.domain.TierTopicInitLeader
 
brokerId() - Method in class kafka.tier.serdes.InitLeader
 
brokerId - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
brokerIdOpt - Variable in class kafka.tier.store.TierObjectStoreConfig
 
BrokerRemovalDescriptionInternal - Class in kafka.common
Class to store status of broker removal progress.
BrokerRemovalDescriptionInternal(int, BalancerOperationStatus, BrokerReplicaExclusionStatus, PartitionReassignmentsStatus, BrokerShutdownStatus, Exception, long, long, boolean) - Constructor for class kafka.common.BrokerRemovalDescriptionInternal
 
BrokerRemovalRequest - Class in kafka.common
A simple internal class with parameters for a broker removal request.
BrokerRemovalRequest(List<Integer>, List<Integer>, Boolean) - Constructor for class kafka.common.BrokerRemovalRequest
 
brokersEligibleForRemoval - Variable in class kafka.common.BrokerRemovalRequest
 
brokerShutdownStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
BrokerShutdownStatusV1 - Enum in kafka.common
This is the very first version of the broker shutdown subtask status of the broker removal operation.
buffer() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
buildFetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>, int) - Method in class kafka.tier.fetcher.TierFetcher
 
bytePosition - Variable in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
 

C

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 - 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
 
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
 
clear() - Method in class kafka.tier.store.encryption.EncryptionKeyManager
Clear the key cache, this is used only for testing.
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.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
 
CLUSTER_ID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
CLUSTER_ID_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
clusterId - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
clusterIdOpt - Variable in class kafka.tier.store.TierObjectStoreConfig
 
commitIntervalMs - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
commitPositions(Iterator<TierPartitionState>) - Method in class kafka.tier.topic.TierTopicConsumer
Commit positions for the provided tier partition states.
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
 
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
 
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
Complete catchup phase for this context and transition to TierPartitionStatus.ONLINE status.
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).
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
 
constraints() - Method in class kafka.common.TopicPlacement.ConstraintCount
 
consumer - Variable in class kafka.tier.tools.TierTopicMaterializationUtils
 
container - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
 
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
 
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.
createBaseInfo(FlatBufferBuilder, int, int, long, long) - Static method in class kafka.durability.events.serdes.BaseInfo
 
createCheckedFileIOHeader(FlatBufferBuilder, byte, long, long) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
createDatabase(FlatBufferBuilder, int, int) - Static method in class kafka.durability.db.serdes.Database
 
createDurabilityPartitionsOffsetsVector(FlatBufferBuilder, long[]) - Static method in class kafka.durability.db.serdes.Header
 
createEmpty() - Static method in class kafka.tier.store.TierObjectStoreConfig
 
createEpochChain(FlatBufferBuilder, int, long) - Static method in class kafka.durability.db.serdes.EpochChain
 
createEventKey(FlatBufferBuilder, int, int) - Static method in class kafka.durability.events.serdes.EventKey
 
createHeader(FlatBufferBuilder, int, int, int) - Static method in class kafka.durability.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
 
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) - Static method in class kafka.durability.db.serdes.PartitionInfo
 
createPartitionsVector(FlatBufferBuilder, int[]) - Static method in class kafka.durability.db.serdes.TopicInfo
 
createTierTopicProducer(Properties, String) - Static method in class kafka.tier.tools.RecoveryUtils
Create and return a new TierTopic Producer object.
createTimeMs() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
createTopicInfo(FlatBufferBuilder, int, int) - Static method in class kafka.durability.db.serdes.TopicInfo
 
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.TierTopicManagerCommitter
 
currentStateTimestamp() - Method in class kafka.internals.generated.GroupMetadataValue
 
currentStatus() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
 
currentStatusLastUpdateTimeMs() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
 

D

Database - Class in kafka.durability.db.serdes
 
Database() - Constructor for class kafka.durability.db.serdes.Database
 
defaultPolicy(int) - Static method in enum kafka.common.TopicPlacement.ObserverPromotionPolicy
 
defaultPolicy() - Static method in enum kafka.common.TopicPlacement.ObserverPromotionPolicy
 
defaultRegistry() - Static method in class kafka.metrics.KafkaYammerMetrics
convenience method to replace Metrics.defaultRegistry()
delayedOperationKeys() - Method in class kafka.tier.fetcher.PendingFetch
Generate DelayedFetch purgatory operation keys
delayedOperationKeys() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
Generate DelayedListOffsets purgatory operation keys
delete() - Method in class kafka.tier.state.FileTierPartitionState
 
delete() - Method in interface kafka.tier.state.TierPartitionState
Delete this TierPartitionState from local storage.
delete(TopicIdPartition) - Method in class kafka.tier.TierReplicaManager
Called when the partition is deleted from this broker.
deleteLatency() - Method in class kafka.tier.store.TierObjectStoreMetrics
 
DeletePartition - Class in kafka.durability.events.serdes
 
DeletePartition() - Constructor for class kafka.durability.events.serdes.DeletePartition
 
DeleteRecords - Class in kafka.durability.events.serdes
 
DeleteRecords() - Constructor for class kafka.durability.events.serdes.DeleteRecords
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.AzureBlockBlobTierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.GcsTierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.S3TierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in interface kafka.tier.store.TierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.TierObjectStoreMetricsEnabled
 
deregister(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicConsumer
Deregister this topic partition and stop materialization.
deserialize(byte[], byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
Deserializes byte key and value read from Tier State Topic into Tier Metadata.
deserialize(ByteBuffer, ByteBuffer) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
deserializeKey(byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
deserializeKey(ByteBuffer) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
dir() - Method in class kafka.tier.state.FileTierPartitionState
 
dir() - Method in interface kafka.tier.state.TierPartitionState
The directory where the TierPartition is stored on disk.
DISABLED - Static variable in class kafka.common.EvenClusterLoadStatusDescriptionInternal
 
doDelete(List<String>, Admin) - Method in class kafka.tools.StreamsResetter
 
downConvert(byte, long, Time) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
doWork() - Method in class kafka.tier.topic.TierTopicConsumer
 
drainThreshold - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
 
DUMP_EVENTS - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
DUMP_EVENTS - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_EVENTS_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_HEADER - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_HEADER_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DumpDurabilityDb - Class in kafka.durability.tools
DurabilityDumpDb is a tool to dump the partition state for TopicState requested from the durability database.
DumpDurabilityDb() - Constructor for class kafka.durability.tools.DumpDurabilityDb
 
dumpEvents - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
dumpHeader - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
dumpRecords - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DumpTierPartitionState - Class in kafka.tier.tools
 
DumpTierPartitionState() - Constructor for class kafka.tier.tools.DumpTierPartitionState
 
dumpTierState(TopicPartition, File, boolean, boolean) - Static method in class kafka.tier.tools.DumpTierPartitionState
 
duplicate() - Method in class kafka.internals.generated.GroupMetadataKey
 
duplicate() - Method in class kafka.internals.generated.GroupMetadataValue
 
duplicate() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
duplicate() - Method in class kafka.internals.generated.OffsetCommitKey
 
duplicate() - Method in class kafka.internals.generated.OffsetCommitValue
 
duplicate() - Method in class kafka.internals.generated.TransactionLogKey
 
duplicate() - Method in class kafka.internals.generated.TransactionLogValue
 
duplicate() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
durabilityPartitionsOffsets(int) - Method in class kafka.durability.db.serdes.Header
 
durabilityPartitionsOffsetsAsByteBuffer() - Method in class kafka.durability.db.serdes.Header
 
durabilityPartitionsOffsetsInByteBuffer(ByteBuffer) - Method in class kafka.durability.db.serdes.Header
 
durabilityPartitionsOffsetsLength() - Method in class kafka.durability.db.serdes.Header
 
durabilityRunId() - Method in class kafka.durability.db.serdes.Header
 

E

EMPTY - Static variable in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
EMPTY - Static variable in class kafka.tier.state.OffsetAndEpoch
 
EMPTY_SNAPSHOT - Static variable in class kafka.common.AliveBrokersSnapshot
 
EMPTY_UUID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
EMPTY_UUID_STR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
emptyFetchResult() - Static method in class kafka.tier.fetcher.TierFetchResult
 
enabled() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
EncryptionKeyManager - Class in kafka.tier.store.encryption
 
EncryptionKeyManager(Time, Metrics, Aead, Duration) - Constructor for class kafka.tier.store.encryption.EncryptionKeyManager
 
EncryptionKeyManager.WellKnownKeypathHook - Interface in kafka.tier.store.encryption
Hook for writing newly created keys to a "well-known" path.
encryptionKeyManagerKeyRotationInterval - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
END_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
END_OFFSET_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
endCheckedFileIOHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
endDatabase(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.Database
 
endDeletePartition(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeletePartition
 
endDeleteRecords(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeleteRecords
 
endEpochChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.EpochChange
 
endEventKey(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.EventKey
 
endHeader(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.Header
 
endHealthCheck(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.HealthCheck
 
endInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
 
endIsrExpand(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.IsrExpand
 
endMaterializationTrackingInfo(FlatBufferBuilder) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
endOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
endOffset() - Method in class kafka.tier.domain.TierPartitionForceRestore
 
endOffset() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
endOffset() - Method in class kafka.tier.serdes.PartitionForceRestore
 
endOffset() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
endOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
endOffset() - Method in class kafka.tier.state.Header
 
endOffset() - Method in class kafka.tier.state.SegmentState
 
endOffset() - Method in interface kafka.tier.state.TierPartitionState
Return the uncommitted end offset spanned by the TierPartitionState.
endOffset - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
endOffsetChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.OffsetChange
 
endOffsetDelta() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
endOffsetDelta() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
endPartitionDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
 
endPartitionDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
endPartitionFence(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionFence
 
endPartitionForceRestore(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
endPartitionInfo(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.PartitionInfo
 
endPartitionUnfreezeLogStartOffset(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
endpoint - Variable in class kafka.tier.store.AzureBlockBlobTierObjectStoreConfig
 
endPosition() - Method in class kafka.tier.serdes.CheckedFileIOHeader
 
endRetentionChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.RetentionChange
 
endSegmentDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
 
endSegmentDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
 
endSegmentUploadComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadComplete
 
endSegmentUploadInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
 
endStartOffsetChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.StartOffsetChange
 
endTierKafkaKey(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierKafkaKey
 
endTierPartitionStateEntry(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
endTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
endTopicInfo(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.TopicInfo
 
ensureValid(String, Object) - Method in class kafka.common.TopicPlacement.TopicPlacementValidator
 
epoch() - Method in class kafka.durability.db.serdes.EpochChain
 
epoch() - Method in class kafka.durability.events.serdes.BaseInfo
 
epoch() - Method in class kafka.tier.serdes.OffsetAndEpoch
 
epoch() - Method in class kafka.tier.state.OffsetAndEpoch
 
EpochChain - Class in kafka.durability.db.serdes
 
EpochChain() - Constructor for class kafka.durability.db.serdes.EpochChain
 
epochChain(int) - Method in class kafka.durability.db.serdes.PartitionInfo
 
epochChain(EpochChain, int) - Method in class kafka.durability.db.serdes.PartitionInfo
 
epochChainLength() - Method in class kafka.durability.db.serdes.PartitionInfo
 
EpochChange - Class in kafka.durability.events.serdes
 
EpochChange() - Constructor for class kafka.durability.events.serdes.EpochChange
 
epochFor(int) - Method in class kafka.common.AliveBrokersSnapshot
Returns the broker epoch for the broker with ID brokerId.
epochStateFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
 
equals(Object) - Method in class kafka.common.AliveBrokersSnapshot
 
equals(Object) - Method in class kafka.common.BalancerStatusDescriptionInternal
 
equals(Object) - Method in class kafka.common.BrokerAdditionDescriptionInternal
 
equals(Object) - Method in class kafka.common.BrokerAddStatus
 
equals(Object) - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
equals(Object) - Method in class kafka.common.BrokerRemovalRequest
 
equals(Object) - Method in class kafka.common.TopicPlacement.ConstraintCount
 
equals(Object) - Method in class kafka.common.TopicPlacement
 
equals(Object) - Method in class kafka.internals.generated.GroupMetadataKey
 
equals(Object) - Method in class kafka.internals.generated.GroupMetadataValue
 
equals(Object) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
equals(Object) - Method in class kafka.internals.generated.OffsetCommitKey
 
equals(Object) - Method in class kafka.internals.generated.OffsetCommitValue
 
equals(Object) - Method in class kafka.internals.generated.TransactionLogKey
 
equals(Object) - Method in class kafka.internals.generated.TransactionLogValue
 
equals(Object) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
equals(Object) - Method in class kafka.tier.domain.AbstractTierMetadata
 
equals(Object) - Method in class kafka.tier.domain.TierObjectMetadata
 
equals(Object) - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
equals(Object) - Method in class kafka.tier.fetcher.offsetcache.FetchKey
 
equals(Object) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
equals(Object) - Method in class kafka.tier.state.Header
 
equals(Object) - Method in class kafka.tier.state.OffsetAndEpoch
 
equals(Object) - Method in class kafka.tier.state.SegmentState
 
equals(Object) - Method in class kafka.tier.store.encryption.CleartextDataKey
 
equals(Object) - Method in class kafka.tier.store.encryption.KeyContext
 
equals(Object) - Method in class kafka.tier.store.encryption.KeySha
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.OpaqueData
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
equals(Object) - Method in class kafka.tier.tools.common.FenceEventInfo
 
equals(Object) - Method in class kafka.tier.TopicIdPartition
 
errorOffsetAndEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
errorOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
errorOffsetAndEpoch() - Method in class kafka.tier.state.Header
 
EvenClusterLoadStatusDescriptionInternal - Class in kafka.common
Class capturing status of any uneven cluster load.
EvenClusterLoadStatusDescriptionInternal(EvenClusterLoadStatus, Long, EvenClusterLoadStatus, Long, Exception) - Constructor for class kafka.common.EvenClusterLoadStatusDescriptionInternal
 
EventKey - Class in kafka.durability.events.serdes
 
EventKey() - Constructor for class kafka.durability.events.serdes.EventKey
 
exception() - Method in class kafka.common.BalancerStatusDescriptionInternal
The nullable #Exception that the balancer component experienced.
exception() - Method in class kafka.common.BrokerAdditionDescriptionInternal
The nullable #Exception that this broker addition operation experienced
exception() - Method in class kafka.common.BrokerRemovalDescriptionInternal
The nullable #Exception that this broker removal operation experienced
exception() - Method in class kafka.common.EvenClusterLoadStatusDescriptionInternal
 
exception - Variable in class kafka.tier.fetcher.TierFetchResult
 
exception - Variable in class kafka.tier.tools.TierMetadataValidator.OffsetValidationResult
 
excludedBrokers() - Method in class kafka.common.ReplicaExclusionCache
Returns a set of the broker IDs that are excluded for replica placement.
exclusions() - Method in class kafka.common.ReplicaExclusionCache
Returns a shallow-copy of a map containing the current broker replica exclusions.
expandBrokerId() - Method in class kafka.durability.events.serdes.IsrExpand
 
expireEntries() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
expireTimestamp() - Method in class kafka.internals.generated.OffsetCommitValue
 
externalLostMessages() - Method in class kafka.durability.db.serdes.PartitionInfo
 
extractTenantPrefix(String) - Static method in class kafka.common.TenantHelpers
 

F

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
 
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
 
fetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>, int) - Method in class kafka.tier.fetcher.TierFetcher
Execute a read for a single partition from Tiered Storage.
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
 
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
 
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) - 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
 
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.
finishCheckedFileIOHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
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
 
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
 
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
 
finishSizePrefixedCheckedFileIOHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
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
 
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
 
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
 
firstBatch() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
firstBatchSize() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
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(Iterator<TierPartitionState>) - Method in class kafka.tier.TierTopicManagerCommitter
Flush TierPartition files to disk and then write consumer offsets 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.
forceMutateState(TierObjectMetadata.State) - Method in class kafka.tier.domain.TierObjectMetadata
To mutate state without canTransitionTo rules checking.
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.
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.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
 

G

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.
generation() - Method in class kafka.internals.generated.GroupMetadataValue
 
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
 
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
 
getChoice() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getException() - Method in class kafka.common.BrokerAddStatus
 
getHeader() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getInput() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getInputStream() - Method in interface kafka.tier.store.TierObjectStoreResponse
 
getLastUpdateTime() - Method in class kafka.common.BrokerAddStatus
 
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
 
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.
getPath() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getRematerialized() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getReplica() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getReplicas() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getRootAsCheckedFileIOHeader(ByteBuffer) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
getRootAsCheckedFileIOHeader(ByteBuffer, CheckedFileIOHeader) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
getRootAsDatabase(ByteBuffer) - Static method in class kafka.durability.db.serdes.Database
 
getRootAsDatabase(ByteBuffer, Database) - Static method in class kafka.durability.db.serdes.Database
 
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.durability.db.serdes.Header
 
getRootAsHeader(ByteBuffer, Header) - Static method in class kafka.durability.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
 
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
 
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
 
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
 
getSegmentPathMap() - Method in class kafka.tier.tools.restore.RestorePartitionOperator
Retrieve the SegmentPath map, which contains all the segments whose state had been flipped from DELETE_COMPLETE to UPLOAD_COMPLETE.
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
 
getStoredKeys() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
Returns the set of keys which are currently stored.
getTierStateFile(TopicIdPartition) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
 
getTypeId(byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
Deserializes just the type from a value read from a Tier State Topic
getValue() - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
Returns the Adler32 checksum value
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
 

H

hasAbortedTxns() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasAbortedTxns() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasAbortedTxns() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasAbortedTxns() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasAbortedTxns() - Method in class kafka.tier.state.SegmentState
 
hasAbortedTxns() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hasEpochState() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasEpochState() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasEpochState() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasEpochState() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasEpochState() - Method in class kafka.tier.state.SegmentState
 
hasEpochState() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hasError() - Method in enum kafka.tier.state.TierPartitionStatus
 
hashCode() - Method in class kafka.common.AliveBrokersSnapshot
 
hashCode() - Method in class kafka.common.BalancerStatusDescriptionInternal
 
hashCode() - Method in class kafka.common.BrokerAdditionDescriptionInternal
 
hashCode() - Method in class kafka.common.BrokerAddStatus
 
hashCode() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
hashCode() - Method in class kafka.common.BrokerRemovalRequest
 
hashCode() - Method in class kafka.common.TopicPlacement.ConstraintCount
 
hashCode() - Method in class kafka.common.TopicPlacement
 
hashCode() - Method in class kafka.internals.generated.GroupMetadataKey
 
hashCode() - Method in class kafka.internals.generated.GroupMetadataValue
 
hashCode() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
hashCode() - Method in class kafka.internals.generated.OffsetCommitKey
 
hashCode() - Method in class kafka.internals.generated.OffsetCommitValue
 
hashCode() - Method in class kafka.internals.generated.TransactionLogKey
 
hashCode() - Method in class kafka.internals.generated.TransactionLogValue
 
hashCode() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
hashCode() - Method in class kafka.tier.domain.AbstractTierMetadata
 
hashCode() - Method in class kafka.tier.domain.TierObjectMetadata
 
hashCode() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hashCode() - Method in class kafka.tier.fetcher.offsetcache.FetchKey
 
hashCode() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
hashCode() - Method in class kafka.tier.state.Header
 
hashCode() - Method in class kafka.tier.state.OffsetAndEpoch
 
hashCode() - Method in class kafka.tier.state.SegmentState
 
hashCode() - Method in class kafka.tier.store.encryption.CleartextDataKey
 
hashCode() - Method in class kafka.tier.store.encryption.KeyContext
 
hashCode() - Method in class kafka.tier.store.encryption.KeySha
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
hashCode() - Method in class kafka.tier.tools.common.FenceEventInfo
 
hashCode() - Method in class kafka.tier.TopicIdPartition
 
hasMatchingMagic(byte) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
hasObserverConstraints() - Method in class kafka.common.TopicPlacement
 
hasProducerState() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasProducerState() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasProducerState() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasProducerState() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasProducerState() - Method in class kafka.tier.state.SegmentState
 
hasProducerState() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
header() - Method in class kafka.durability.db.serdes.Database
 
header(Header) - Method in class kafka.durability.db.serdes.Database
 
Header - Class in kafka.durability.db.serdes
 
Header() - Constructor for class kafka.durability.db.serdes.Header
 
Header - Class in kafka.tier.state
Header for the tier partition state file.
Header(UUID, byte, int, TierPartitionStatus, long, long, OffsetAndEpoch, OffsetAndEpoch, OffsetAndEpoch, OffsetAndEpoch) - Constructor for class kafka.tier.state.Header
 
header - Variable in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
header - Variable in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
header() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
header() - Method in class kafka.tier.tools.restore.RestorePartitionOperator
 
HealthCheck - Class in kafka.durability.events.serdes
 
HealthCheck() - Constructor for class kafka.durability.events.serdes.HealthCheck
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataKey
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataValue
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.OffsetCommitKey
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.OffsetCommitValue
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogKey
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogValue
 
HIGHEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
highestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataKey
 
highestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataValue
 
highestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
highestSupportedVersion() - Method in class kafka.internals.generated.OffsetCommitKey
 
highestSupportedVersion() - Method in class kafka.internals.generated.OffsetCommitValue
 
highestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogKey
 
highestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogValue
 
highestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
highWatermark() - Method in class kafka.durability.db.serdes.PartitionInfo
 
highWatermark() - Method in class kafka.durability.events.serdes.BaseInfo
 
hitRatio() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 

I

id() - Method in class kafka.common.TopicPlacement.Replica
 
id() - Method in enum kafka.tier.domain.TierObjectMetadata.State
 
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
 
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
 
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.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(AdminZkClient, 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
 
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.
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.topic.TierTopicManagerConfig
 
intoByteArray() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
 
intoLongArray() - Method in class kafka.tier.store.TierObjectStore.OpaqueData
 
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
 
isDisabled() - Method in class kafka.tier.fetcher.MemoryTracker
Returns true if this MemoryTracker is disabled.
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
 
isNewTopic() - Method in class kafka.assignor.TopicReplicaAssignor.NewPartitions
 
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.
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.
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
 

J

jsonToList(Path) - Static method in class kafka.tier.tools.common.FenceEventInfo
 

K

kafka.assignor - package kafka.assignor
 
kafka.common - package kafka.common
 
kafka.durability.db.serdes - package kafka.durability.db.serdes
 
kafka.durability.events.serdes - package kafka.durability.events.serdes
 
kafka.durability.tools - package kafka.durability.tools
 
kafka.internals.generated - package kafka.internals.generated
 
kafka.metrics - package kafka.metrics
 
kafka.tier - package kafka.tier
 
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.tools.restore - package kafka.tier.tools.restore
 
kafka.tier.topic - package kafka.tier.topic
 
kafka.tools - package kafka.tools
 
kafka.utils.checksum - package kafka.utils.checksum
 
kafkaTopicId() - Method in class kafka.tier.TopicIdPartition
 
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.
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
 

L

lastLocalMaterializedSrcOffsetAndEpoch() - Method in class kafka.tier.state.FileTierPartitionState
 
lastLocalMaterializedSrcOffsetAndEpoch() - Method in interface kafka.tier.state.TierPartitionState
Return the last materialized source offset and epoch
lastOffset() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
lastUpdateTimeMs() - Method in class kafka.common.BrokerAdditionDescriptionInternal
 
lastUpdateTimeMs() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
lastUsed() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
LATEST_VERSION - Static variable in class kafka.common.TopicPlacement
 
leader() - Method in class kafka.internals.generated.GroupMetadataValue
 
leaderEpoch() - Method in class kafka.internals.generated.OffsetCommitValue
 
LeaderEpoch(Logger, TopicIdPartition, CompletableFuture<Optional<TierLogSegment>>, int) - Constructor for class kafka.tier.state.FileTierPartitionState.MaterializationListener.LeaderEpoch
 
leased() - Method in class kafka.tier.fetcher.MemoryTracker
Returns the number of bytes currently leased
leased() - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
Returns the amount of memory currently leased by this MemoryLease.
leastSignificantBits() - Method in class kafka.tier.serdes.UUID
 
length() - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
length returns the length till which checksum has been calculated.
length() - Method in interface kafka.utils.checksum.ChecksumWithInPlaceUpdate
Return the length of file till which the checksum has been calculated.
listToJson(List<FenceEventInfo>) - Static method in class kafka.tier.tools.common.FenceEventInfo
 
localMaterializedEpoch() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
localMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
localMaterializedOffsetAndEpoch() - Method in class kafka.tier.state.Header
 
logDirs - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
logStartOffset() - Method in class kafka.durability.events.serdes.BaseInfo
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataKey
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataValue
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.OffsetCommitKey
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.OffsetCommitValue
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogKey
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogValue
 
LOWEST_SUPPORTED_VERSION - Static variable in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
lowestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataKey
 
lowestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataValue
 
lowestSupportedVersion() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
lowestSupportedVersion() - Method in class kafka.internals.generated.OffsetCommitKey
 
lowestSupportedVersion() - Method in class kafka.internals.generated.OffsetCommitValue
 
lowestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogKey
 
lowestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogValue
 
lowestSupportedVersion() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 

M

main(String[]) - Static method in class kafka.durability.tools.DumpDurabilityDb
 
main(String[]) - Static method in class kafka.tier.tools.DumpTierPartitionState
 
main(String[]) - Static method in class kafka.tier.tools.restore.RestoreTierPartitionState
 
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.tier.state.FileTierPartitionIterator
 
makeNext() - Method in class kafka.tier.tools.restore.SegmentStateIterator
 
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.
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
 
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
 
messageId() - Method in class kafka.tier.domain.AbstractTierMetadata
Get a unique id for this message.
messageId() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
 
messageId() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
 
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.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.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
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, TierObjectStoreConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStore
 
MockInMemoryTierObjectStore(Time, Metrics, TierObjectStoreConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStore
 
mostSignificantBits() - Method in class kafka.tier.serdes.UUID
 
mutateBaseOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateChecksum(long) - Method in class kafka.tier.serdes.CheckedFileIOHeader
 
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
 
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
 
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
 

N

name(int) - Static method in class kafka.tier.serdes.ObjectState
 
NAME_TO_NULL_CALLBACK - Static variable in class kafka.common.TenantHelpers
 
NAME_TO_TENANT_CALLBACK - Static variable in class kafka.common.TenantHelpers
 
names - Static variable in class kafka.tier.serdes.ObjectState
 
newContext() - Static method in class kafka.tier.fetcher.CancellationContext
Create a new root CancellationContext.
newLease(CancellationContext, long) - Method in class kafka.tier.fetcher.MemoryTracker
Creates a new MemoryLease if the pool contains a positive amount of bytes.
NewPartitions(String, int, int, short) - Constructor for class kafka.assignor.TopicReplicaAssignor.NewPartitions
 
NextOffsetAndBatchMetadata(FetchOffsetMetadata, long) - Constructor for class kafka.tier.fetcher.TierSegmentReader.NextOffsetAndBatchMetadata
 
NO_CHECKSUM_SUPER_BLOCK_LENGTH_DEFAULT - Static variable in class kafka.utils.checksum.NoChecksumFileIO
The super block length for NO_CHECKSUM should always be 0.
NoChecksumFileIO - Class in kafka.utils.checksum
NoChecksumFileIO is an I/O package which extends CheckedFileIO and is used for ChecksumAlgorithm type NO_CHECKSUM.
nonExistentBrokers - Variable in class kafka.common.BrokerRemovalRequest
 
numFetchThreads - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
numPartitions() - Method in interface kafka.tier.topic.InitializedTierTopic
 
numPartitions() - Method in class kafka.tier.topic.TierTopic
 
numSegments(long, long) - Method in class kafka.tier.state.FileTierPartitionState
 
numSegments() - Method in class kafka.tier.state.FileTierPartitionState
 
numSegments() - Method in interface kafka.tier.state.TierPartitionState
Scan the ObjectMetadata (segment) entries in this tier partition, and return the count.
numSegments(long, long) - Method in interface kafka.tier.state.TierPartitionState
Count of the number of segments lying within a range

O

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(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
 
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
 
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.
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.
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.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
 
overrideMap(Map<Integer, String>) - Method in class kafka.common.ReplicaExclusionCache
 

P

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.durability.db.serdes.PartitionInfo
 
partition() - Method in class kafka.durability.events.serdes.EventKey
 
partition() - Method in class kafka.internals.generated.OffsetCommitKey
 
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
 
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
 
PartitionFence - Class in kafka.tier.serdes
 
PartitionFence() - Constructor for class kafka.tier.serdes.PartitionFence
 
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
 
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.
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
 
PartitionUnfreezeLogStartOffset - Class in kafka.tier.serdes
 
PartitionUnfreezeLogStartOffset() - Constructor for class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
path() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
path() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
 
payloadBuffer() - Method in class kafka.tier.domain.AbstractTierMetadata
 
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.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
 
PendingOffsetForTimestamp - Class in kafka.tier.fetcher
 
pollDuration - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
poolSize() - Method in class kafka.tier.fetcher.MemoryTracker
 
position() - Method in class kafka.tier.state.FileTierPartitionIterator
 
position() - Method in class kafka.tier.tools.restore.SegmentStateIterator
 
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.
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
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.
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
 
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
 

R

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
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
 
ReclaimableMemoryRecords - Class in kafka.tier.fetcher
 
ReclaimableMemoryRecords(ByteBuffer, Optional<MemoryTracker.MemoryLease>) - Constructor for class kafka.tier.fetcher.ReclaimableMemoryRecords
 
reconfigurableConfigs() - Method in class kafka.metrics.KafkaYammerMetrics
 
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.fetcher.TierFetcher
 
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
 
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
 
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
 
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
 
replicas() - Method in class kafka.common.TopicPlacement
 
replicas() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
 
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
 
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.tier.tools.common.RestoreInfo.RestoreComparatorOutput
 
restore() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
 
restore() - Method in class kafka.tier.tools.restore.RestorePartitionOperator
 
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_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
 
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
 
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
 
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
 
RestorePartitionOperator - Class in kafka.tier.tools.restore
 
RestorePartitionOperator(TopicPartition, File, long, String) - Constructor for class kafka.tier.tools.restore.RestorePartitionOperator
 
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
 
RestoreTierPartitionState - Class in kafka.tier.tools.restore
This tool is for restoring segment's state in FTPS file based on timestamp input.
RestoreTierPartitionState() - Constructor for class kafka.tier.tools.restore.RestoreTierPartitionState
 
result - Variable in class kafka.tier.tools.TierMetadataValidator.OffsetValidationResult
 
results() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
 
RetentionChange - Class in kafka.durability.events.serdes
 
RetentionChange() - Constructor for class kafka.durability.events.serdes.RetentionChange
 
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
 
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
 

S

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
 
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
 
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.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_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
 
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).
segmentNumberWithState(TierObjectMetadata.State) - Method in class kafka.tier.tools.restore.RestorePartitionOperator
 
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.
SegmentState - Class in kafka.tier.state
 
SegmentState(TierObjectMetadata, long, long) - Constructor for class kafka.tier.state.SegmentState
 
SegmentState(int, UUID, long, long, long, long, int, TierObjectMetadata.State, boolean, boolean, boolean, TierObjectStore.OpaqueData, long) - Constructor for class kafka.tier.state.SegmentState
 
segmentStateByObjectID(UUID) - Method in class kafka.tier.tools.restore.RestorePartitionOperator
 
SegmentStateIterator - Class in kafka.tier.tools.restore
 
SegmentStateIterator(TopicIdPartition, CheckedFileIO, long) - Constructor for class kafka.tier.tools.restore.SegmentStateIterator
 
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
 
serializeKey() - Method in class kafka.tier.domain.AbstractTierMetadata
 
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
 
setAssignment(byte[]) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setClientHost(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setClientId(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setCommitTimestamp(long) - Method in class kafka.internals.generated.OffsetCommitValue
 
setCurrentStateTimestamp(long) - Method in class kafka.internals.generated.GroupMetadataValue
 
setException(Exception) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
setExpireTimestamp(long) - Method in class kafka.internals.generated.OffsetCommitValue
 
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
 
setGroupInstanceId(String) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setHeader(Header) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
setLastUpdateTime(long) - Method in class kafka.common.BrokerAddStatus
 
setLeader(String) - Method in class kafka.internals.generated.GroupMetadataValue
 
setLeaderEpoch(int) - Method in class kafka.internals.generated.OffsetCommitValue
 
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
 
setOffset(long) - Method in class kafka.internals.generated.OffsetCommitValue
 
setPartition(int) - Method in class kafka.internals.generated.OffsetCommitKey
 
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.
setProducerEpoch(short) - Method in class kafka.internals.generated.TransactionLogValue
 
setProducerId(long) - Method in class kafka.internals.generated.TransactionLogValue
 
setProtocol(String) - Method in class kafka.internals.generated.GroupMetadataValue
 
setProtocolType(String) - Method in class kafka.internals.generated.GroupMetadataValue
 
setRebalanceTimeout(int) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setSessionTimeout(int) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
setStartTime(long) - Method in class kafka.common.BrokerAddStatus
 
setSubscription(byte[]) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
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.
setTopic(String) - Method in class kafka.internals.generated.OffsetCommitKey
 
setTopic(String) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
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
 
setupConsumer(TierTopicMaterializationToolConfig) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
 
setValidationSuccess(boolean) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
shiftOffsetsBy(Consumer<byte[], byte[]>, Set<TopicPartition>, long) - Method in class kafka.tools.StreamsResetter
 
shouldShutdown - Variable in class kafka.common.BrokerRemovalRequest
 
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
 
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.tier.topic.TierTopicConsumer
 
START_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
START_OFFSET_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
startCheckedFileIOHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.CheckedFileIOHeader
 
startDatabase(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.Database
 
startDeletePartition(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeletePartition
 
startDeleteRecords(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.DeleteRecords
 
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.durability.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
 
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
 
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
 
startPartitionsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.TopicInfo
 
startPartitionUnfreezeLogStartOffset(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
startRetentionChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.RetentionChange
 
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
 
startStartOffsetChange(FlatBufferBuilder) - Static method in class kafka.durability.events.serdes.StartOffsetChange
 
startTierKafkaKey(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierKafkaKey
 
startTierPartitionStateEntry(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
startTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
startTopicInfo(FlatBufferBuilder) - Static method in class kafka.durability.db.serdes.TopicInfo
 
startTopicsVector(FlatBufferBuilder, int) - Static method in class kafka.durability.db.serdes.Database
 
startup() - Method in class kafka.tier.topic.TierTopicManager
 
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
 
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.TierPartitionDeleteComplete
 
stateOffsetAndEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
 
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.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
 
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.
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.
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
 

T

TENANT_PREFIX_REGEX - Static variable in class kafka.common.TenantHelpers
 
TenantHelpers - Class in kafka.common
 
TenantHelpers() - Constructor for class kafka.common.TenantHelpers
 
throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
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
 
tierEpoch() - Method in class kafka.tier.domain.AbstractTierMetadata
tierEpoch for the tier metadata
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.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.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
 
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, int, TierObjectMetadata.State, boolean, boolean, boolean, TierObjectStore.OpaqueData) - Constructor for class kafka.tier.domain.TierObjectMetadata
 
TierObjectMetadata(TierSegmentUploadInitiate) - 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.DataTypePathPrefix - Enum in kafka.tier.store
 
TierObjectStore.FileType - Enum in kafka.tier.store
 
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
 
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
 
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) - 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, int, boolean, boolean, boolean, 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) - 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<AdminZkClient>) - Constructor for class kafka.tier.topic.TierTopicManager
Instantiate TierTopicManager.
TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<AdminZkClient>) - 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) - Constructor for class kafka.tier.client.TierTopicProducerSupplier
 
TierUtils - Class in kafka.tier.state
 
TierUtils() - Constructor for class kafka.tier.state.TierUtils
 
timeMs() - Method in class kafka.durability.events.serdes.RetentionChange
 
timeStamp() - Method in class kafka.durability.events.serdes.HealthCheck
 
timestampIndexFetched() - Method in class kafka.tier.store.TierObjectStoreMetrics
 
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(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.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.durability.db.serdes.TopicInfo
 
topic() - Method in class kafka.internals.generated.OffsetCommitKey
 
topic() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
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
 
topicAsByteBuffer() - Method in class kafka.durability.db.serdes.TopicInfo
 
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
 
topicIdBase64 - Variable in class kafka.tier.tools.common.FenceEventInfo
 
topicIdBase64() - Method in class kafka.tier.tools.common.FenceEventInfo
 
topicIdPartition() - Method in class kafka.tier.domain.AbstractTierMetadata
Topic-partition corresponding to this tier metadata.
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.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.durability.db.serdes.TopicInfo
 
TopicInfo - Class in kafka.durability.db.serdes
 
TopicInfo() - Constructor for class kafka.durability.db.serdes.TopicInfo
 
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
 
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
A builder for the configurable TopicReplicaAssignor class.
topics(int) - Method in class kafka.durability.db.serdes.Database
 
topics(TopicInfo, int) - Method in class kafka.durability.db.serdes.Database
 
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.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.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.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.TierSegmentReader.NextOffsetAndBatchMetadata
 
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.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.
totalSegments() - Method in class kafka.tier.tools.restore.RestorePartitionOperator
Retrieve the total number of segments in the tier partition state file
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
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.TierPartitionDeleteComplete
 
type() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
 
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
 

U

underlying() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
UNFREEZE_LOG_START_OFFSET_INPUT - Static variable in class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
 
UNFREEZE_LOG_START_OFFSET_INPUT_DOC - Static variable in class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
 
UNFREEZE_LOG_START_OFFSET_OUTPUT - Static variable in class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
 
UNFREEZE_LOG_START_OFFSET_OUTPUT_DOC - Static variable in class kafka.tier.tools.TierPartitionUnfreezeLogStartOffsetTrigger
 
unfreezeEvent() - Method in class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
 
UnfreezeTriggerOutput(RestoreInfo.RestoreRawOutput, String) - Constructor for class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
 
UNKNOWN_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
unknownTaggedFields() - Method in class kafka.internals.generated.GroupMetadataKey
 
unknownTaggedFields() - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
unknownTaggedFields() - Method in class kafka.internals.generated.GroupMetadataValue
 
unknownTaggedFields() - Method in class kafka.internals.generated.OffsetCommitKey
 
unknownTaggedFields() - Method in class kafka.internals.generated.OffsetCommitValue
 
unknownTaggedFields() - Method in class kafka.internals.generated.TransactionLogKey
 
unknownTaggedFields() - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
unknownTaggedFields() - Method in class kafka.internals.generated.TransactionLogValue
 
update(int) - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
Append a byte at the end and update the checksum NOTE: This operation is not supported and append(ByteBuffer) should be used instead
update(byte[], int, int) - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
Update a byte array of length len from position off and update the checksum NOTE: This operation is not supported as in many cases it helps not reading the existing bytes as the application can provide from its cache.
update(ByteBuffer, ByteBuffer, long) - Method in class kafka.utils.checksum.Adler32WithInPlaceUpdate
This method performs in place update operation, by replacing previous bytes at offset 'position' with 'updated' bytes and updates the checksum value.
update(ByteBuffer, ByteBuffer, long) - Method in interface kafka.utils.checksum.ChecksumWithInPlaceUpdate
In-place update a buffer at offset and update the checksum.
updateClusterMetadata(Cluster) - Method in interface kafka.assignor.TopicReplicaAssignorBuilder
Refresh the latest cluster metadata.
updateDir(File) - Method in class kafka.tier.state.FileTierPartitionState
 
updateDir(File) - Method in interface kafka.tier.state.TierPartitionState
Update the directory reference for the log and indices in this segment.
updateLastUsed(long) - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
updatePosition(int, OffsetAndEpoch) - Method in class kafka.tier.TierTopicManagerCommitter
Update position materialized by the TierTopicManager consumer.
updatePredicate(Predicate<MetricName>) - Method in class kafka.metrics.FilteringJmxReporter
 
updateSegmentState(UUID, TierObjectMetadata.State) - Method in class kafka.tier.tools.restore.RestorePartitionOperator
 
updateState(TierObjectMetadata.State) - Method in class kafka.tier.state.SegmentState
Return a new SegmentState with the updated state
userPartition - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
userTopicId - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
UUID - Class in kafka.tier.serdes
 
UUID() - Constructor for class kafka.tier.serdes.UUID
 

V

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
 
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.
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.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.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.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.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.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.
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.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.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.InitLeader
 
version() - Method in class kafka.tier.serdes.PartitionDeleteComplete
 
version() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
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
 
versionInByte() - Method in class kafka.tier.state.Header
 

W

wakeup() - Method in class kafka.tier.fetcher.MemoryTracker
Wakeup all threads which are waiting on a memory lease.
workDir - Variable in class kafka.tier.tools.TierMetadataValidator
 
WORKING_DIR - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
WORKING_DIR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
WORKING_DIR_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataKey
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue.MemberMetadata
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.GroupMetadataValue
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitKey
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.OffsetCommitValue
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogKey
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue.PartitionsSchema
 
write(Writable, ObjectSerializationCache, short, MessageContext) - Method in class kafka.internals.generated.TransactionLogValue
 
write(ByteBuffer) - Method in class kafka.utils.checksum.Adler32CheckedFileIO
 
write(ByteBuffer, long) - Method in class kafka.utils.checksum.Adler32CheckedFileIO
 
write(ByteBuffer) - Method in class kafka.utils.checksum.CheckedFileIO
Write the given buffer into the file channel at the relative file channel position NOTE: File position is updated with the number of bytes written
write(ByteBuffer, long) - Method in class kafka.utils.checksum.CheckedFileIO
Write the given buffer into the file channel at the input relative position in file channel.
write(ByteBuffer) - Method in class kafka.utils.checksum.NoChecksumFileIO
 
write(ByteBuffer, long) - Method in class kafka.utils.checksum.NoChecksumFileIO
 
writeFullyTo(GatheringByteChannel) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
writeHeader(CheckedFileIO, Header) - Static method in class kafka.tier.state.FileTierPartitionState
 
writeJsonToFile(List<ComparatorInfo.ComparatorOutput>, Path) - Static method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
writeJsonToFile(List<RestoreInfo.RestoreComparatorInput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
 
writeJsonToFile(List<RestoreInfo.RestoreComparatorOutput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
 
writeJsonToFile(List<RestoreInfo.RestoreRawInput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
 
writeJsonToFile(List<RestoreInfo.RestoreRawOutput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
 
writeJsonToFile(List<RestoreInfo.UnfreezeTriggerOutput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.UnfreezeTriggerOutput
 
writeTo(TransferableChannel, long, int) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class kafka.tier.topic.TierMessageFormatter
 
writeWellKnownPathMetadata(Map<String, String>) - Method in interface kafka.tier.store.encryption.EncryptionKeyManager.WellKnownKeypathHook
Writes the provided metadata to the TierObjectStore-specific "well-known" path.

Z

ZEROED - Static variable in class kafka.tier.store.TierObjectStore.OpaqueData
 

_

__assign(int, ByteBuffer) - Method in class kafka.durability.db.serdes.Database
 
__assign(int, ByteBuffer) - Method in class kafka.durability.db.serdes.EpochChain
 
__assign(int, ByteBuffer) - Method in class kafka.durability.db.serdes.Header
 
__assign(int, ByteBuffer) - Method in class kafka.durability.db.serdes.PartitionInfo
 
__assign(int, ByteBuffer) - Method in class kafka.durability.db.serdes.TopicInfo
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.BaseInfo
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.DeletePartition
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.DeleteRecords
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.EpochChange
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.EventKey
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.HealthCheck
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.IsrExpand
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.OffsetChange
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.RetentionChange
 
__assign(int, ByteBuffer) - Method in class kafka.durability.events.serdes.StartOffsetChange
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.CheckedFileIOHeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.InitLeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.OffsetAndEpoch
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.OpaqueDataField
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionFence
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.UUID
 
__init(int, ByteBuffer) - Method in class kafka.durability.db.serdes.Database
 
__init(int, ByteBuffer) - Method in class kafka.durability.db.serdes.EpochChain
 
__init(int, ByteBuffer) - Method in class kafka.durability.db.serdes.Header
 
__init(int, ByteBuffer) - Method in class kafka.durability.db.serdes.PartitionInfo
 
__init(int, ByteBuffer) - Method in class kafka.durability.db.serdes.TopicInfo
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.BaseInfo
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.DeletePartition
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.DeleteRecords
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.EpochChange
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.EventKey
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.HealthCheck
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.IsrExpand
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.OffsetChange
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.RetentionChange
 
__init(int, ByteBuffer) - Method in class kafka.durability.events.serdes.StartOffsetChange
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.CheckedFileIOHeader
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.InitLeader
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.OffsetAndEpoch
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.OpaqueDataField
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionFence
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionUnfreezeLogStartOffset
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.UUID
 
A B C D E F G H I J K L M N O P R S T U V W Z _ 
Skip navigation links