- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-