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

A

abortedTxns - Variable in class kafka.tier.fetcher.TierFetchResult
 
AbstractTierMetadata - Class in kafka.tier.domain
 
AbstractTierMetadata() - Constructor for class kafka.tier.domain.AbstractTierMetadata
 
AbstractTierSegmentMetadata - Class in kafka.tier.domain
Represents metadata for a particular segment.
AbstractTierSegmentMetadata() - Constructor for class kafka.tier.domain.AbstractTierSegmentMetadata
 
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.tier.serdes.InitLeader
 
addContentHash(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
addControllerEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
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
 
addErrorOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
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
 
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
 
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
 
addPartition(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierKafkaKey
 
addRestoreOffsetAndEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
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.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
 
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.tier.serdes.TierKafkaKey
 
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.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
 
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.
assumeRoleArn - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
attributes() - Method in class kafka.common.TopicPlacement.Replica
 
AutoAbortingS3InputStream - Class in kafka.tier.store
An input stream wrapper which decides to close or abort an S3ObjectInputStream based on the remaining data left in the stream.
available() - Method in class kafka.tier.store.AutoAbortingS3InputStream
 

B

baseOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
baseOffset() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
baseOffset() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
baseOffset() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
baseOffset() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
batches() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
batchIterator() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
becomeArchiver(TopicIdPartition, int) - Method in interface kafka.tier.topic.TierTopicAppender
Performs a write to the tier topic to attempt to become leader for the tiered topic partition.
becomeArchiver(TopicIdPartition, int) - Method in class kafka.tier.topic.TierTopicManager
Performs a write to the tier topic to attempt to become leader for the tiered topic partition.
becomeFollower(TierPartitionState) - Method in class kafka.tier.TierReplicaManager
Called when replica becomes follower.
becomeLeader(TierPartitionState, int) - Method in class kafka.tier.TierReplicaManager
Called when replica is elected to be the leader.
beginCatchup() - Method in class kafka.tier.state.FileTierPartitionState
 
beginCatchup() - Method in interface kafka.tier.state.TierPartitionState
Begin catchup phase for tier partition state.
beginCatchup() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Begin TierPartitionStatus.CATCHUP phase for this context.
BOOTSTRAP_SERVER_CONFIG - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
BOOTSTRAP_SERVER_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
BROKER_WORKDIR_LIST - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
BrokerAddStatus - Class in kafka.common
Class to store status of broker add progress.
BrokerAddStatus(int, Exception) - Constructor for class kafka.common.BrokerAddStatus
 
brokerId() - Method in class kafka.common.BrokerAddStatus
 
brokerId() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
brokerId() - Method in class kafka.tier.domain.TierTopicInitLeader
 
brokerId() - Method in class kafka.tier.serdes.InitLeader
 
brokerId - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
brokerIdOpt - Variable in class kafka.tier.store.TierObjectStoreConfig
 
BrokerRemovalDescriptionInternal - Class in kafka.common
Class to store status of broker removal progress.
BrokerRemovalDescriptionInternal(int, BrokerRemovalDescription.BrokerShutdownStatus, BrokerRemovalDescription.PartitionReassignmentsStatus, Exception) - Constructor for class kafka.common.BrokerRemovalDescriptionInternal
 
brokerShutdownStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
buffer() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
buildFetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>, int) - Method in class kafka.tier.fetcher.TierFetcher
 
bytePosition - Variable in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
 

C

CachedFetchOffsetMetadata - Class in kafka.tier.fetcher.offsetcache
 
CachedFetchOffsetMetadata(FetchOffsetMetadata, long) - Constructor for class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
cancel() - Method in class kafka.tier.fetcher.CancellationContext
Cancel this CancellationContext, causing all sub-CancellationContexts to cancel.
cancel() - Method in class kafka.tier.fetcher.PendingFetch
Cancel the pending fetch.
cancel() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
Cancel the request
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.
choice() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
 
cleanup() - Method in class kafka.tier.topic.TierTopicConsumer
 
client(S3TierObjectStoreConfig) - Static method in class kafka.tier.store.S3TierObjectStore
 
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.AutoAbortingS3InputStream
 
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 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
 
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.
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
 
completeCatchup() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Complete catchup phase for this context and transition to TierPartitionStatus.ONLINE status.
completeExceptionally(TopicPartition, Exception) - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
Complete a TimestampAndOffset request exceptionally.
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
 
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
 
createEmpty() - Static method in class kafka.tier.store.TierObjectStoreConfig
 
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
 
createTierTopicProducer(Properties, String) - Static method in class kafka.tier.tools.RecoveryUtils
Create and return a new TierTopic Producer object.
createUUID(FlatBufferBuilder, long, long) - Static method in class kafka.tier.serdes.UUID
 
CURRENT_VERSION - Static variable in class kafka.tier.TierTopicManagerCommitter
 

D

defaultRegistry() - Static method in class kafka.metrics.KafkaYammerMetrics
convenience method to replace Metrics.defaultRegistry()
delayedOperationKeys() - Method in class kafka.tier.fetcher.PendingFetch
Generate DelayedFetch purgatory operation keys
delayedOperationKeys() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
Generate DelayedListOffsets purgatory operation keys
delete() - Method in class kafka.tier.state.FileTierPartitionState
 
delete() - Method in interface kafka.tier.state.TierPartitionState
Delete this TierPartitionState from local storage.
delete(TopicIdPartition) - Method in class kafka.tier.TierReplicaManager
Called when the partition is deleted from this broker.
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.GcsTierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.store.S3TierObjectStore
 
deleteSegment(TierObjectStore.ObjectMetadata) - Method in interface kafka.tier.store.TierObjectStore
 
deregister(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicConsumer
Deregister this topic partition and stop materialization.
deserialize(byte[], byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
Deserializes byte key and value read from Tier State Topic into Tier Metadata.
deserialize(ByteBuffer, ByteBuffer) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
deserializeKey(byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
deserializeKey(ByteBuffer) - Static method in class kafka.tier.domain.AbstractTierMetadata
 
dir() - Method in class kafka.tier.state.FileTierPartitionState
 
dir() - Method in interface kafka.tier.state.TierPartitionState
The directory where the TierPartition is stored on disk.
doDelete(List<String>, Admin) - Method in class kafka.tools.StreamsResetter
 
downConvert(byte, long, Time) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
doWork() - Method in class kafka.tier.topic.TierTopicConsumer
 
DUMP_EVENTS - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
DUMP_EVENTS - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_EVENTS_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_HEADER - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DUMP_METADATA_HEADER_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
dumpEvents - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
dumpHeader - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
dumpRecords - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
DumpTierPartitionState - Class in kafka.tier.tools
 
DumpTierPartitionState() - Constructor for class kafka.tier.tools.DumpTierPartitionState
 
dumpTierState(TopicPartition, File, boolean) - Static method in class kafka.tier.tools.DumpTierPartitionState
 
duplicate() - Method in class kafka.tier.domain.TierObjectMetadata
 

E

EMPTY - Static variable in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
EMPTY - Static variable in class kafka.tier.state.OffsetAndEpoch
 
EMPTY_UUID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
EMPTY_UUID_STR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
emptyFetchResult() - Static method in class kafka.tier.fetcher.TierFetchResult
 
enabled() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
END_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
END_OFFSET_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
endInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
 
endMaterializationTrackingInfo(FlatBufferBuilder) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
endOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
endOffset() - Method in class kafka.tier.domain.TierPartitionForceRestore
 
endOffset() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
endOffset() - Method in class kafka.tier.serdes.PartitionForceRestore
 
endOffset() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
endOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
endOffset() - Method in class kafka.tier.state.Header
 
endOffset() - Method in interface kafka.tier.state.TierPartitionState
Return the uncommitted end offset spanned by the TierPartitionState.
endOffset - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
endOffsetDelta() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
endOffsetDelta() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
endPartitionDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
 
endPartitionDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
endPartitionFence(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionFence
 
endPartitionForceRestore(FlatBufferBuilder) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
endSegmentDeleteComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
 
endSegmentDeleteInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
 
endSegmentUploadComplete(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadComplete
 
endSegmentUploadInitiate(FlatBufferBuilder) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
 
endTierKafkaKey(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierKafkaKey
 
endTierPartitionStateEntry(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
endTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
ensureValid(String, Object) - Method in class kafka.common.TopicPlacement.TopicPlacementValidator
 
epoch() - Method in class kafka.tier.serdes.OffsetAndEpoch
 
epoch() - Method in class kafka.tier.state.OffsetAndEpoch
 
equals(Object) - Method in class kafka.common.BrokerAddStatus
 
equals(Object) - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
equals(Object) - Method in class kafka.common.TopicPlacement.ConstraintCount
 
equals(Object) - Method in class kafka.common.TopicPlacement
 
equals(Object) - Method in class kafka.tier.domain.AbstractTierMetadata
 
equals(Object) - Method in class kafka.tier.domain.TierObjectMetadata
 
equals(Object) - Method in class kafka.tier.fetcher.offsetcache.FetchKey
 
equals(Object) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
equals(Object) - Method in class kafka.tier.state.Header
 
equals(Object) - Method in class kafka.tier.state.OffsetAndEpoch
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
equals(Object) - Method in class kafka.tier.TierTimestampAndOffset
 
equals(Object) - Method in class kafka.tier.tools.common.FenceEventInfo
 
equals(Object) - Method in class kafka.tier.TopicIdPartition
 
errorOffsetAndEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
errorOffsetAndEpoch(OffsetAndEpoch) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
errorOffsetAndEpoch() - Method in class kafka.tier.state.Header
 
exception() - Method in class kafka.common.BrokerRemovalDescriptionInternal
The nullable #Exception that this broker removal operation experienced
exception - Variable in class kafka.tier.fetcher.TierFetchResult
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.AbstractTierMetadata
Test method for validating initial buffer size allocation
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierPartitionFence
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierPartitionForceRestore
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierSegmentUploadComplete
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
expectedSizeLatestVersion() - Method in class kafka.tier.domain.TierTopicInitLeader
 
expireEntries() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
extractTenantPrefix(String) - Static method in class kafka.common.TenantHelpers
 

F

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, 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, TierTimestampAndOffset>, 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
 
FILE_FENCE_TARGET_PARTITIONS_CONFIG - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
 
FILE_FENCE_TARGET_PARTITIONS_DOC - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
 
FileTierPartitionIterator - Class in kafka.tier.state
 
FileTierPartitionIterator(TopicIdPartition, FileChannel, 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) - Constructor for class kafka.tier.state.FileTierPartitionState
 
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.
finishInitLeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
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
 
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
 
finishSizePrefixedInitLeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
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
 
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
 
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
 
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
 
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.
flushedPath() - Method in class kafka.tier.state.FileTierPartitionState
 
fromByte(byte) - Static method in enum kafka.tier.state.TierPartitionStatus
 

G

gcsBucket - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
gcsCredFilePath - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
gcsPrefix - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
gcsRegion - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
GcsTierObjectStore - Class in kafka.tier.store
 
GcsTierObjectStore(GcsTierObjectStoreConfig) - Constructor for class kafka.tier.store.GcsTierObjectStore
 
GcsTierObjectStoreConfig - Class in kafka.tier.store
 
GcsTierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.GcsTierObjectStoreConfig
 
GcsTierObjectStoreConfig(Optional<String>, Optional<Integer>, String, String, String, Integer, String) - Constructor for class kafka.tier.store.GcsTierObjectStoreConfig
 
gcsWriteChunkSize - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
generateBackendConfig(TierObjectStore.Backend, Properties) - Static method in class kafka.tier.store.TierObjectStoreUtils
This method generates the TierStoreConfig for the various backends.
get() - Method in class kafka.tier.client.TierTopicConsumerSupplier
 
get() - Method in class kafka.tier.client.TierTopicProducerSupplier
 
get(UUID, long) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
getBackend() - Method in class kafka.tier.store.GcsTierObjectStore
 
getBackend() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getBackend() - Method in class kafka.tier.store.S3TierObjectStore
 
getBackend() - Method in interface kafka.tier.store.TierObjectStore
 
getChoice() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getDateTime(String) - Method in class kafka.tools.StreamsResetter
 
getException() - Method in class kafka.common.BrokerAddStatus
 
getHeader() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getInput() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getInputStream() - Method in interface kafka.tier.store.TierObjectStoreResponse
 
getLastUpdateTime() - Method in class kafka.common.BrokerAddStatus
 
getName() - Method in enum kafka.tier.store.TierObjectStore.Backend
 
getNumPartitions(Producer<byte[], byte[]>, String) - Static method in class kafka.tier.tools.RecoveryUtils
Discovers and returns the number of partitions in the provided topicName.
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.GcsTierObjectStore
 
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.S3TierObjectStore
 
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
 
getObjectCounts() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getPath() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getRematerialized() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getReplica() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
getReplicas() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
getRootAsInitLeader(ByteBuffer) - Static method in class kafka.tier.serdes.InitLeader
 
getRootAsInitLeader(ByteBuffer, InitLeader) - Static method in class kafka.tier.serdes.InitLeader
 
getRootAsMaterializationTrackingInfo(ByteBuffer) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
getRootAsMaterializationTrackingInfo(ByteBuffer, MaterializationTrackingInfo) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
getRootAsPartitionDeleteComplete(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
 
getRootAsPartitionDeleteComplete(ByteBuffer, PartitionDeleteComplete) - Static method in class kafka.tier.serdes.PartitionDeleteComplete
 
getRootAsPartitionDeleteInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
getRootAsPartitionDeleteInitiate(ByteBuffer, PartitionDeleteInitiate) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
getRootAsPartitionFence(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionFence
 
getRootAsPartitionFence(ByteBuffer, PartitionFence) - Static method in class kafka.tier.serdes.PartitionFence
 
getRootAsPartitionForceRestore(ByteBuffer) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
getRootAsPartitionForceRestore(ByteBuffer, PartitionForceRestore) - Static method in class kafka.tier.serdes.PartitionForceRestore
 
getRootAsSegmentDeleteComplete(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
 
getRootAsSegmentDeleteComplete(ByteBuffer, SegmentDeleteComplete) - Static method in class kafka.tier.serdes.SegmentDeleteComplete
 
getRootAsSegmentDeleteInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
 
getRootAsSegmentDeleteInitiate(ByteBuffer, SegmentDeleteInitiate) - Static method in class kafka.tier.serdes.SegmentDeleteInitiate
 
getRootAsSegmentUploadComplete(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentUploadComplete
 
getRootAsSegmentUploadComplete(ByteBuffer, SegmentUploadComplete) - Static method in class kafka.tier.serdes.SegmentUploadComplete
 
getRootAsSegmentUploadInitiate(ByteBuffer) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
 
getRootAsSegmentUploadInitiate(ByteBuffer, SegmentUploadInitiate) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
 
getRootAsTierKafkaKey(ByteBuffer) - Static method in class kafka.tier.serdes.TierKafkaKey
 
getRootAsTierKafkaKey(ByteBuffer, TierKafkaKey) - Static method in class kafka.tier.serdes.TierKafkaKey
 
getRootAsTierPartitionStateEntry(ByteBuffer) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
getRootAsTierPartitionStateEntry(ByteBuffer, TierPartitionStateEntry) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
getRootAsTierPartitionStateHeader(ByteBuffer) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
getRootAsTierPartitionStateHeader(ByteBuffer, TierPartitionStateHeader) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
getStartOffset(TopicPartition) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
getStartOffset will return the beginning offset of a given TopicPartition 'tp'.
getStartTime() - Method in class kafka.common.BrokerAddStatus
 
getStored() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getTierStateFile(TopicIdPartition) - Method in class kafka.tier.tools.TierTopicMaterializationUtils
 
getTypeId(byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
Deserializes just the type from a value read from a Tier State Topic
globalMaterializedEpoch() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
globalMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
globalMaterializedOffsetAndEpoch() - Method in class kafka.tier.state.Header
 

H

hasAbortedTxns() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasAbortedTxns() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasAbortedTxns() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasAbortedTxns() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasAbortedTxns() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hasCompatibleMagic(byte) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
hasEpochState() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasEpochState() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasEpochState() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasEpochState() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasEpochState() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hasError() - Method in enum kafka.tier.state.TierPartitionStatus
 
hashCode() - Method in class kafka.common.BrokerAddStatus
 
hashCode() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
hashCode() - Method in class kafka.common.TopicPlacement.ConstraintCount
 
hashCode() - Method in class kafka.common.TopicPlacement
 
hashCode() - Method in class kafka.tier.domain.AbstractTierMetadata
 
hashCode() - Method in class kafka.tier.domain.TierObjectMetadata
 
hashCode() - Method in class kafka.tier.fetcher.offsetcache.FetchKey
 
hashCode() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
hashCode() - Method in class kafka.tier.state.Header
 
hashCode() - Method in class kafka.tier.state.OffsetAndEpoch
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
hashCode() - Method in class kafka.tier.TierTimestampAndOffset
 
hashCode() - Method in class kafka.tier.tools.common.FenceEventInfo
 
hashCode() - Method in class kafka.tier.TopicIdPartition
 
hasMatchingMagic(byte) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
hasObserverConstraints() - Method in class kafka.common.TopicPlacement
 
hasProducerState() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasProducerState() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
hasProducerState() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
hasProducerState() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
hasProducerState() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
Header - Class in kafka.tier.state
Header for the tier partition state file.
header - Variable in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
header - Variable in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
header() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
hitRatio() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 

I

id() - Method in class kafka.common.TopicPlacement.Replica
 
id() - Method in enum kafka.tier.domain.TierObjectMetadata.State
 
init(Properties) - Method in class kafka.tier.topic.TierMessageFormatter
 
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) - Method in class kafka.tier.state.TierPartitionStateFactory
 
injectFencingEvents(Properties, String, List<TopicIdPartition>) - 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
 
INSTANCE - Static variable in class kafka.metrics.KafkaYammerMetrics
 
interBrokerClientConfigs - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
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
 
isOpen() - Method in enum kafka.tier.state.TierPartitionStatus
 
isOpenForWrite() - Method in enum kafka.tier.state.TierPartitionStatus
 
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.
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
 
isValidStates(Iterator<TierObjectMetadata>, Iterator<TierObjectMetadata>, long, Optional<TierObjectStore>, boolean, CancellationContext, Function<TopicPartition, Long>) - Static method in class kafka.tier.tools.TierMetadataValidator
 
iterator(TopicPartition, FileChannel) - Static method in class kafka.tier.state.FileTierPartitionState
 

J

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

K

kafka.common - package kafka.common
 
kafka.metrics - package kafka.metrics
 
kafka.tier - package kafka.tier
 
kafka.tier.client - package kafka.tier.client
 
kafka.tier.domain - package kafka.tier.domain
 
kafka.tier.exceptions - package kafka.tier.exceptions
 
kafka.tier.fetcher - package kafka.tier.fetcher
 
kafka.tier.fetcher.offsetcache - package kafka.tier.fetcher.offsetcache
 
kafka.tier.serdes - package kafka.tier.serdes
 
kafka.tier.state - package kafka.tier.state
 
kafka.tier.store - package kafka.tier.store
 
kafka.tier.tools - package kafka.tier.tools
 
kafka.tier.tools.common - package kafka.tier.tools.common
 
kafka.tier.topic - package kafka.tier.topic
 
kafka.tools - package kafka.tools
 
KafkaYammerMetrics - Class in kafka.metrics
This class encapsulates the default yammer metrics registry for Kafka server, and configures the set of exported JMX metrics for Yammer metrics.
keyPath(TierObjectStore.ObjectStoreMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 

L

lastLocalMaterializedSrcOffsetAndEpoch() - Method in class kafka.tier.state.FileTierPartitionState
 
lastLocalMaterializedSrcOffsetAndEpoch() - Method in interface kafka.tier.state.TierPartitionState
Return the last materialized source offset and epoch
lastOffset() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
lastUsed() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
leaderEpoch() - Method in class kafka.tier.TierTimestampAndOffset
 
leased() - Method in class kafka.tier.fetcher.MemoryTracker
Returns the number of bytes currently leased
leased() - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
Returns the amount of memory currently leased by this MemoryLease.
leastSignificantBits() - Method in class kafka.tier.serdes.UUID
 
listToJson(List<FenceEventInfo>) - Static method in class kafka.tier.tools.common.FenceEventInfo
 
localMaterializedEpoch() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
localMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
localMaterializedOffsetAndEpoch() - Method in class kafka.tier.state.Header
 
logDirs - Variable in class kafka.tier.topic.TierTopicManagerConfig
 

M

main(String[]) - Static method in class kafka.tier.tools.DumpTierPartitionState
 
main(String[]) - Static method in class kafka.tier.tools.TierMetadataComparator
 
main(String[]) - Static method in class kafka.tier.tools.TierMetadataDebugger
 
main(String[]) - Static method in class kafka.tier.tools.TierMetadataValidator
 
main(String[]) - Static method in class kafka.tier.tools.TierPartitionStateFencingTrigger
 
main(String[]) - Static method in class kafka.tier.tools.TierPartitionStateRestoreTrigger
 
main(String[]) - Static method in class kafka.tools.StreamsResetter
 
makeArgument(String) - Static method in class kafka.tier.tools.RecoveryUtils
 
makeNext() - Method in class kafka.tier.state.FileTierPartitionIterator
 
markFetchExpired() - Method in class kafka.tier.fetcher.PendingFetch
 
matches(Map<String, String>) - Method in class kafka.common.TopicPlacement.ConstraintCount
 
matchesInternalTopicFormat(String) - 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
 
materializationPath - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
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
 
materializeUpto(long) - Method in class kafka.tier.state.FileTierPartitionState
 
materializeUpto(long) - Method in interface kafka.tier.state.TierPartitionState
Sets up a listener for this tier partition state for use by the replica fetcher.
materializeUptoEpoch(int) - Method in class kafka.tier.state.FileTierPartitionState
 
materializeUptoEpoch(int) - Method in interface kafka.tier.state.TierPartitionState
Sets up a listener for this tier partition state.
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
 
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.
maybeSeekToEnd(String, Consumer<byte[], byte[]>, Set<TopicPartition>) - Method in class kafka.tools.StreamsResetter
 
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
 
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.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
 
messageIdAsBase64() - Method in class kafka.tier.domain.AbstractTierMetadata
Encode messageId with Base64
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.TierTimestampAndOffset
 
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
 
MockInMemoryTierObjectStore - Class in kafka.tier.store
 
MockInMemoryTierObjectStore(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
 
mutateEndOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateEndOffsetDelta(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateGlobalMaterializedEpoch(int) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
mutateGlobalMaterializedOffset(long) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
mutateHasAbortedTxns(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateHasEpochState(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateHasProducerState(boolean) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateLocalMaterializedEpoch(int) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
mutateLocalMaterializedOffset(long) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
mutateMaxTimestamp(long) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateSize(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateStartOffset(long) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateState(TierObjectMetadata.State) - Method in class kafka.tier.domain.TierObjectMetadata
 
mutateState(byte) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateStatus(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateTierEpoch(int) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateTierEpoch(int) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateVersion(byte) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
mutateVersion(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 

N

name(int) - Static method in class kafka.tier.serdes.ObjectState
 
names - Static variable in class kafka.tier.serdes.ObjectState
 
newContext() - Static method in class kafka.tier.fetcher.CancellationContext
Create a new root CancellationContext.
newLease(CancellationContext, long) - Method in class kafka.tier.fetcher.MemoryTracker
Creates a new MemoryLease if the pool contains a positive amount of bytes.
NextOffsetAndBatchMetadata(FetchOffsetMetadata, long) - Constructor for class kafka.tier.fetcher.TierSegmentReader.NextOffsetAndBatchMetadata
 
numFetchThreads - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
numPartitions() - Method in interface kafka.tier.topic.InitializedTierTopic
 
numPartitions() - Method in class kafka.tier.topic.TierTopic
 
numSegments(long, long) - Method in class kafka.tier.state.FileTierPartitionState
 
numSegments() - Method in class kafka.tier.state.FileTierPartitionState
 
numSegments() - Method in interface kafka.tier.state.TierPartitionState
Scan the ObjectMetadata (segment) entries in this tier partition, and return the count.
numSegments(long, long) - Method in interface kafka.tier.state.TierPartitionState
Count of the number of segments lying within a range

O

objectId() - Method in class kafka.tier.domain.AbstractTierSegmentMetadata
A unique identifier for the segment.
objectId() - Method in class kafka.tier.domain.TierObjectMetadata
Random ID associated with each TierObjectMetadata entry.
objectId() - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
objectId(UUID) - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
objectId() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
objectId(UUID) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
objectId() - Method in class kafka.tier.serdes.SegmentUploadComplete
 
objectId(UUID) - Method in class kafka.tier.serdes.SegmentUploadComplete
 
objectId() - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
objectId(UUID) - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
objectId() - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
objectId(UUID) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
objectId() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
objectIdAsBase64() - Method in class kafka.tier.domain.AbstractTierSegmentMetadata
Encode objectId with Base64
objectIdAsBase64() - Method in class kafka.tier.domain.TierObjectMetadata
 
objectIdAsBase64() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
ObjectMetadata(TopicIdPartition, UUID, int, long, boolean, boolean, boolean) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
 
ObjectMetadata(TierObjectMetadata) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
 
objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
objectMetadata(Optional<String>, Optional<Integer>) - Method in interface kafka.tier.store.TierObjectStore.ObjectStoreMetadata
Converts an ObjectStoreMetadata to a map of metadata that may be useful to place on objects in object storage, if this functionality is present in the object store implementation of choice
objectMetadata(Optional<String>, Optional<Integer>) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
ObjectState - Class in kafka.tier.serdes
 
observers() - Method in class kafka.common.TopicPlacement
 
of(int, Map<String, String>) - Static method in class kafka.common.TopicPlacement.ConstraintCount
 
of(int, Optional<Map<String, String>>) - Static method in class kafka.common.TopicPlacement.Replica
Returns a Replica from the id and set of attributes.
offset() - Method in class kafka.tier.serdes.OffsetAndEpoch
 
offset() - Method in class kafka.tier.state.OffsetAndEpoch
 
OffsetAndEpoch - Class in kafka.tier.serdes
 
OffsetAndEpoch() - Constructor for class kafka.tier.serdes.OffsetAndEpoch
 
OffsetAndEpoch - Class in kafka.tier.state
 
OffsetAndEpoch(long, Optional<Integer>) - Constructor for class kafka.tier.state.OffsetAndEpoch
 
OffsetAndEpoch(OffsetAndEpoch) - Constructor for class kafka.tier.state.OffsetAndEpoch
 
offsetCacheExpirationMs - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
offsetCacheExpiryPeriodMs - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
offsetCacheSize - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
offsetForTimestamp(CancellationContext, InputStream, long, int) - Method in class kafka.tier.fetcher.TierSegmentReader
Read the supplied input stream to find the first offset with a timestamp >= targetTimestamp
onBecomeFollower(TopicIdPartition) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
Fired when this topic partition becomes follower.
onBecomeLeader(TopicIdPartition, int) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
Fired when this topic partition becomes leader.
onCatchUpComplete() - Method in class kafka.tier.state.FileTierPartitionState
 
onCatchUpComplete() - Method in interface kafka.tier.state.TierPartitionState
Mark catchup completed for tier partition state.
onDelete(TopicIdPartition) - Method in interface kafka.tier.TierReplicaManager.ChangeListener
Fired when this topic partition is deleted.
onMetricAdded(MetricName, Metric) - Method in class kafka.metrics.FilteringJmxReporter
 
onMetricRemoved(MetricName) - Method in class kafka.metrics.FilteringJmxReporter
 
OUTPUT_CONFIG - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
 
OUTPUT_CONFIG_DOC - Static variable in class kafka.tier.tools.TierPartitionStateFencingTrigger
 

P

parse(String) - Static method in class kafka.common.TopicPlacement
 
partition() - Method in class kafka.tier.serdes.TierKafkaKey
 
partition - Variable in class kafka.tier.tools.common.FenceEventInfo
 
partition() - Method in class kafka.tier.tools.common.FenceEventInfo
 
partition - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
partition() - Method in class kafka.tier.TopicIdPartition
 
PartitionDeleteComplete - Class in kafka.tier.serdes
 
PartitionDeleteComplete() - Constructor for class kafka.tier.serdes.PartitionDeleteComplete
 
PartitionDeleteInitiate - Class in kafka.tier.serdes
 
PartitionDeleteInitiate() - Constructor for class kafka.tier.serdes.PartitionDeleteInitiate
 
PartitionFence - Class in kafka.tier.serdes
 
PartitionFence() - Constructor for class kafka.tier.serdes.PartitionFence
 
PartitionForceRestore - Class in kafka.tier.serdes
 
PartitionForceRestore() - Constructor for class kafka.tier.serdes.PartitionForceRestore
 
partitionId(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicPartitioner
Determine the Tier Topic partition that should contain metadata for a given tiered TopicIdPartition
partitionReassignmentsStatus() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
partitions(String, int) - Static method in class kafka.tier.topic.TierTopicManager
 
path() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
 
path() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
 
payloadBuffer() - Method in class kafka.tier.domain.AbstractTierMetadata
 
payloadBuffer() - Method in class kafka.tier.domain.TierObjectMetadata
 
payloadBuffer() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
 
payloadBuffer() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
 
payloadBuffer() - Method in class kafka.tier.domain.TierPartitionFence
 
payloadBuffer() - Method in class kafka.tier.domain.TierPartitionForceRestore
 
payloadBuffer() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
 
payloadBuffer() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
 
payloadBuffer() - Method in class kafka.tier.domain.TierSegmentUploadComplete
 
payloadBuffer() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
payloadBuffer() - Method in class kafka.tier.domain.TierTopicInitLeader
 
payloadSize() - Method in class kafka.tier.domain.TierObjectMetadata
 
PendingFetch - Class in kafka.tier.fetcher
 
PendingOffsetForTimestamp - Class in kafka.tier.fetcher
 
pollDuration - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
poolSize() - Method in class kafka.tier.fetcher.MemoryTracker
 
position() - Method in class kafka.tier.state.FileTierPartitionIterator
 
positionFor(int) - Method in class kafka.tier.TierTopicManagerCommitter
Return the current position and epoch for the given tier topic partition.
prefixWithTenant(String, TopicPartition) - Static method in class kafka.common.TenantHelpers
 
process(AbstractTierMetadata, OffsetAndEpoch) - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Process metadata for this context.
properties(TierTopicManagerConfig, String) - Static method in class kafka.tier.client.TierTopicProducerSupplier
 
props - Variable in class kafka.tier.tools.TierMetadataValidator
 
put(UUID, long, int, OptionalInt) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
put(UUID, long, FetchOffsetMetadata) - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 
putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.GcsTierObjectStore
 
putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in class kafka.tier.store.S3TierObjectStore
 
putObject(TierObjectStore.ObjectStoreMetadata, File, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.GcsTierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in class kafka.tier.store.S3TierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<ByteBuffer>) - Method in interface kafka.tier.store.TierObjectStore
 

R

read() - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
read(byte[]) - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
read(byte[], int, int) - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
readBatch(InputStream, int) - Method in class kafka.tier.fetcher.TierSegmentReader
Reads one full batch from an InputStream.
readHeader(FileChannel) - 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
 
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.
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.
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
 
replicas() - Method in class kafka.common.TopicPlacement
 
replicas() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
 
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
 
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
 
restore() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
 
restore() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
 
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.
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
 
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
 
restoreState(TierPartitionForceRestore, ByteBuffer, TierPartitionStatus, OffsetAndEpoch) - Method in class kafka.tier.state.FileTierPartitionState
 
restoreState(TierPartitionForceRestore, ByteBuffer, TierPartitionStatus, OffsetAndEpoch) - Method in interface kafka.tier.state.TierPartitionState
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.
restoreState(TierPartitionForceRestore, ByteBuffer, TierPartitionStatus, OffsetAndEpoch) - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Process restore for this context
results() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
 
run() - Method in class kafka.tier.fetcher.PendingFetch
 
run() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
 
run() - Method in class kafka.tier.tools.TierMetadataComparator
The core logic of the Comparator tool can be broken down into the following 4 steps: 1.
run() - Method in class kafka.tier.tools.TierMetadataValidator
 
run() - Method in class kafka.tier.tools.TierTopicMaterializationUtils
 
run() - Method in class kafka.tier.topic.TierTopicConsumer
 
run() - Method in class kafka.tier.topic.TierTopicManager
 
run(String[]) - Method in class kafka.tools.StreamsResetter
 
run(String[], Properties) - Method in class kafka.tools.StreamsResetter
 

S

s3AutoAbortThresholdBytes - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3Bucket - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3CredFilePath - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3EndpointOverride - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
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
 
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) - Constructor for class kafka.tier.store.S3TierObjectStoreConfig
 
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
 
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.
segmentSize - Variable in class kafka.tier.TierTimestampAndOffset
 
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
 
setException(Exception) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
setHeader(Header) - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
 
setLastUpdateTime(long) - Method in class kafka.common.BrokerAddStatus
 
setPoolSize(long) - Method in class kafka.tier.fetcher.MemoryTracker
Set a new pool size for the Memory Tracker.
setStartTime(long) - Method in class kafka.common.BrokerAddStatus
 
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.
setTopicId(UUID) - Method in class kafka.tier.state.FileTierPartitionState
 
setTopicId(UUID) - Method in interface kafka.tier.state.TierPartitionState
Sets the TopicIdPartition for this TierPartitionState.
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
 
shutdown() - Method in class kafka.tier.topic.TierTopicConsumer
 
shutdown() - Method in class kafka.tier.topic.TierTopicManager
Shutdown the tier topic manager.
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
 
sizeInBytes() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
skip(long) - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
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.tier.topic.TierTopicConsumer
 
START_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
START_OFFSET_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
startInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
 
startMaterializationTrackingInfo(FlatBufferBuilder) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
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
 
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
 
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
 
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
 
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
 
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.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.
suffix() - Method in enum kafka.tier.store.TierObjectStore.FileType
 

T

TENANT_PREFIX_REGEX - Static variable in class kafka.common.TenantHelpers
 
TenantHelpers - Class in kafka.common
 
TenantHelpers() - Constructor for class kafka.common.TenantHelpers
 
throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
TIER_PROPERTIES_CONF_FILE_CONFIG - Static variable in class kafka.tier.tools.RecoveryUtils
 
TIER_PROPERTIES_CONF_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.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 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, Optional<TierObjectStore>) - 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(Properties, List<FenceEventInfo>, Path) - 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.
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) - 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.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
 
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) - 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) - 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.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) - 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
 
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) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
 
TierSegmentUploadInitiate(TopicIdPartition, SegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
 
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
 
TierTimestampAndOffset - Class in kafka.tier
 
TierTimestampAndOffset(long, TierObjectStore.ObjectMetadata, int) - Constructor for class kafka.tier.TierTimestampAndOffset
 
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>) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
 
TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, Properties) - 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
 
timestamp - Variable in class kafka.tier.TierTimestampAndOffset
 
timestamp() - Method in class kafka.tier.TierTimestampAndOffset
 
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
 
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 - Variable in class kafka.tier.tools.common.FenceEventInfo
 
topic() - Method in class kafka.tier.tools.common.FenceEventInfo
 
topic() - Method in class kafka.tier.TopicIdPartition
 
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.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
 
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.tier.serdes.TierKafkaKey
 
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.Replica - Class in kafka.common
 
TopicPlacement.TopicPlacementValidator - Class in kafka.common
 
toSend(String) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
toState(byte) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
 
toString() - Method in class kafka.common.BrokerRemovalDescriptionInternal
 
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.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.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
 
toString() - Method in class kafka.tier.state.Header
 
toString() - Method in class kafka.tier.state.OffsetAndEpoch
 
toString() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
toString() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 
toString() - Method in class kafka.tier.TierTimestampAndOffset
 
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.TopicIdPartition
 
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
 
toTopicIdPartitions(List<String>) - Static method in class kafka.tier.tools.RecoveryUtils
Converts a list of formatted TopicIdPartition strings to a list of TopicIdPartition.
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.
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.TierSegmentDeleteComplete
 
type() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
 
type() - Method in class kafka.tier.domain.TierSegmentUploadComplete
 
type() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
 
type() - Method in class kafka.tier.domain.TierTopicInitLeader
 

U

underlying() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
UNKNOWN_OFFSET - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
updateDir(File) - Method in class kafka.tier.state.FileTierPartitionState
 
updateDir(File) - Method in interface kafka.tier.state.TierPartitionState
Update the directory reference for the log and indices in this segment.
updateLastUsed(long) - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
updatePosition(int, OffsetAndEpoch) - Method in class kafka.tier.TierTopicManagerCommitter
Update position materialized by the TierTopicManager consumer.
updatePredicate(Predicate<MetricName>) - Method in class kafka.metrics.FilteringJmxReporter
 
userPartition - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
userTopicId - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
UUID - Class in kafka.tier.serdes
 
UUID() - Constructor for class kafka.tier.serdes.UUID
 

V

VALIDATE - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
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.
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
 
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.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.
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.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.
version() - Method in class kafka.common.TopicPlacement
 
version() - Method in class kafka.tier.domain.TierObjectMetadata
 
version() - Method in class kafka.tier.domain.TierPartitionForceRestore
 
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.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.store.TierObjectStore.TierStateRestoreSnapshotMetadata
 

W

wakeup() - Method in class kafka.tier.fetcher.MemoryTracker
Wakeup all threads which are waiting on a memory lease.
workDir - Variable in class kafka.tier.tools.TierMetadataValidator
 
WORKING_DIR - Static variable in class kafka.tier.tools.TierRecoveryConfig
 
WORKING_DIR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
WORKING_DIR_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
writeFullyTo(GatheringByteChannel) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
writeJsonToFile(List<ComparatorInfo.ComparatorOutput>, Path) - Static method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
 
writeJsonToFile(List<RestoreInfo.RestoreComparatorInput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
 
writeJsonToFile(List<RestoreInfo.RestoreComparatorOutput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
 
writeJsonToFile(List<RestoreInfo.RestoreRawInput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
 
writeJsonToFile(List<RestoreInfo.RestoreRawOutput>, OutputStream) - Static method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
 
writeTo(GatheringByteChannel, long, int) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
 
writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class kafka.tier.topic.TierMessageFormatter
 

_

__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.InitLeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.OffsetAndEpoch
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionFence
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.UUID
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.InitLeader
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.OffsetAndEpoch
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionFence
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentDeleteInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.SegmentUploadInitiate
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateEntry
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.UUID
 
A B C D E F G H I J K L M N O P R S T U V W _ 
Skip navigation links