Skip navigation links
A B C D E F G H I 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
 
addBrokerId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
addControllerEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.PartitionDeleteInitiate
 
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
 
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.
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
 
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
 
addSize(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.SegmentUploadInitiate
 
addSize(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
addState(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateEntry
 
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.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, long) - Method in class kafka.tier.state.FileTierPartitionState
 
append(AbstractTierMetadata, long) - Method in interface kafka.tier.state.TierPartitionState
Appends abstract metadata to the tier partition.
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
 
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
 
brokerId() - Method in class kafka.tier.domain.TierTopicInitLeader
 
brokerId() - Method in class kafka.tier.serdes.InitLeader
 
brokerId - Variable in class kafka.tier.store.TierObjectStoreConfig
 
brokerId - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
buildFetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>) - 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.
cleanup() - Method in class kafka.tier.topic.TierTopicConsumer
 
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.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 class kafka.tier.topic.TierMessageFormatter
 
closeHandlers() - Method in class kafka.tier.state.FileTierPartitionState
 
closeHandlers() - Method in interface kafka.tier.state.TierPartitionState
 
clusterId - Variable in class kafka.tier.store.TierObjectStoreConfig
 
clusterId - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
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.
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.
config - Variable in class kafka.tier.tools.TierTopicMaterializationUtils
 
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
 
controllerEpoch() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
count() - Method in class kafka.common.TopicPlacement.ConstraintCount
 
createMaterializationTrackingInfo(FlatBufferBuilder, long, long) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
 
createSegmentMetadata(TierObjectStore.ObjectMetadata, String, int) - Static method in class kafka.tier.store.TierObjectStoreUtils
Returns a Map containing the metadata of a segment.
createUUID(FlatBufferBuilder, long, long) - Static method in class kafka.tier.serdes.UUID
 

D

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
 
doWork() - Method in class kafka.tier.topic.TierTopicConsumer
 
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_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
 
enableTierConfig() - Method in class kafka.tier.state.FileTierPartitionState
 
enableTierConfig() - Method in interface kafka.tier.state.TierPartitionState
Called when tiering is enabled for this tier topic partition.
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.TierSegmentUploadInitiate
 
endOffset() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
endOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
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
 
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
 
ensureTopic(int, short) - Method in class kafka.tier.topic.TierTopic
Check if tier topic exists.
ensureValid(String, Object) - Method in class kafka.common.TopicPlacement.TopicPlacementValidator
 
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.state.Header
 
equals(Object) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
equals(Object) - Method in class kafka.tier.TierTimestampAndOffset
 
equals(Object) - Method in class kafka.tier.TopicIdPartition
 
exception - Variable in class kafka.tier.fetcher.TierFetchResult
 
expireEntries() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetCache
 

F

fencedSegments() - Method in class kafka.tier.state.FileTierPartitionState
 
fencedSegments() - Method in interface kafka.tier.state.TierPartitionState
 
fetch(List<TierFetchMetadata>, IsolationLevel, Consumer<DelayedOperationKey>) - 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
 
fetchLeaderEpochState(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
 
fetchProducerStateSnapshot(TierObjectStore.ObjectMetadata) - Method in class kafka.tier.fetcher.TierStateFetcher
 
fetchPropertiesFromArgs(String[]) - Static method in class kafka.tier.tools.TierMetadataDebugger
 
FileTierPartitionIterator - Class in kafka.tier.state
 
FileTierPartitionIterator(TopicIdPartition, FileChannel, long) - Constructor for class kafka.tier.state.FileTierPartitionIterator
 
FileTierPartitionState - Class in kafka.tier.state
 
FileTierPartitionState(File, TopicPartition, boolean) - Constructor for class kafka.tier.state.FileTierPartitionState
 
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
 
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
 
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
 
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.
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
 
gcsReadChunkSize - 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(String, KafkaConfig) - Constructor for class kafka.tier.store.GcsTierObjectStoreConfig
 
gcsWriteChunkSize - Variable in class kafka.tier.store.GcsTierObjectStoreConfig
 
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
 
getDateTime(String) - Method in class kafka.tools.StreamsResetter
 
getInputStream() - Method in interface kafka.tier.store.TierObjectStoreResponse
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.GcsTierObjectStore
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType, Integer, Integer) - Method in class kafka.tier.store.S3TierObjectStore
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType, Integer, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore
 
getObjectCounts() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
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
 
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
 
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
globalMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
globalMaterializedOffset() - 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
 
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
 
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.state.Header
 
hashCode() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
hashCode() - Method in class kafka.tier.TierTimestampAndOffset
 
hashCode() - Method in class kafka.tier.TopicIdPartition
 
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
 
Header - Class in kafka.tier.state
Header for the tier partition state file.
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(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) - Method in class kafka.tier.state.TierPartitionStateFactory
 
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
 
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.
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.
iterator(TopicPartition, FileChannel) - Static method in class kafka.tier.state.FileTierPartitionState
 

K

kafka.common - package kafka.common
 
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.topic - package kafka.tier.topic
 
kafka.tools - package kafka.tools
 
keyPath(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
keyPath(TierObjectStore.ObjectMetadata, TierObjectStore.FileType) - Static method in class kafka.tier.store.TierObjectStoreUtils
Returns a String of the key path for the given object metadata and file type.

L

lastUsed() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
 
leaderEpoch() - Method in class kafka.tier.TierTimestampAndOffset
 
leastSignificantBits() - Method in class kafka.tier.serdes.UUID
 
localMaterializedOffset() - Method in class kafka.tier.serdes.MaterializationTrackingInfo
 
localMaterializedOffset() - 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.TierMetadataDebugger
 
main(String[]) - Static method in class kafka.tier.tools.TierMetadataValidator
 
main(String[]) - Static method in class kafka.tools.StreamsResetter
 
makeNext() - Method in class kafka.tier.state.FileTierPartitionIterator
 
matches(Map<String, String>) - Method in class kafka.common.TopicPlacement.ConstraintCount
 
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
 
materializationListener(long) - Method in class kafka.tier.state.FileTierPartitionState
 
materializationListener(long) - Method in interface kafka.tier.state.TierPartitionState
Sets up a listener for this tier partition state for use by the replica fetcher.
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.TierTopicMaterializationToolConfig
 
materialize - Variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
MATERIALIZE_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
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
 
maybeSeekToEnd(String, Consumer<byte[], byte[]>, Set<TopicPartition>) - Method in class kafka.tools.StreamsResetter
 
mayEnableTiering(TopicPartition, LogConfig) - Method in class kafka.tier.state.TierPartitionStateFactory
 
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.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
 
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
 
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
 
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
 
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.
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() - 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.

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) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
 
ObjectMetadata(TierObjectMetadata) - Constructor for class kafka.tier.store.TierObjectStore.ObjectMetadata
 
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.
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.

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.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
 
partitionId(TopicIdPartition) - Method in class kafka.tier.topic.TierTopicPartitioner
Determine the Tier Topic partition that should contain metadata for a given tiered TopicIdPartition
partitions(String, int) - Static method in class kafka.tier.topic.TierTopicManager
 
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.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
 
PendingFetch - Class in kafka.tier.fetcher
 
PendingOffsetForTimestamp - Class in kafka.tier.fetcher
 
pollDuration - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
position() - Method in class kafka.tier.state.FileTierPartitionIterator
 
positionFor(int) - Method in class kafka.tier.TierTopicManagerCommitter
Return the current position for the given tier topic partition.
process(AbstractTierMetadata, long) - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
Process metadata for this context.
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
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<File>) - Method in class kafka.tier.store.GcsTierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<File>) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<File>) - Method in class kafka.tier.store.S3TierObjectStore
 
putSegment(TierObjectStore.ObjectMetadata, File, File, File, Optional<File>, Optional<ByteBuffer>, Optional<File>) - 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
readRecords(CancellationContext, InputStream, int, long, int, int) - Method in class kafka.tier.fetcher.TierSegmentReader
Loads records from a given InputStream up to maxBytes.
recordBatchSize - Variable in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
 
records - Variable in class kafka.tier.fetcher.TierFetchResult
 
RecordsAndNextBatchMetadata(MemoryRecords, TierSegmentReader.NextOffsetAndBatchMetadata) - Constructor for class kafka.tier.fetcher.TierSegmentReader.RecordsAndNextBatchMetadata
 
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.
replicas() - Method in class kafka.common.TopicPlacement
 
requestTimeoutMs - Variable in class kafka.tier.topic.TierTopicManagerConfig
 
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
 
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.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
 
s3AwsAccessKeyId - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3AwsSecretAccessKey - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3bucket - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3EndpointOverride - Variable in class kafka.tier.store.S3TierObjectStoreConfig
 
s3MultipartUploadSize - 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
 
S3TierObjectStore - Class in kafka.tier.store
 
S3TierObjectStore(S3TierObjectStoreConfig) - Constructor for class kafka.tier.store.S3TierObjectStore
 
S3TierObjectStoreConfig - Class in kafka.tier.store
 
S3TierObjectStoreConfig(String, KafkaConfig) - 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
 
segmentOffsets() - Method in class kafka.tier.state.FileTierPartitionState
 
segmentOffsets(long, long) - Method in class kafka.tier.state.FileTierPartitionState
 
segmentOffsets() - Method in interface kafka.tier.state.TierPartitionState
Get the set of base offsets for all tiered segments.
segmentOffsets(long, long) - Method in interface kafka.tier.state.TierPartitionState
Get the set of base offsets for all 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
 
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
 
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
 
skip(long) - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
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.state.FileTierPartitionState
 
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
 
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
 
stateMap - Variable in class kafka.tier.tools.TierTopicMaterializationUtils
 
status() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
status() - Method in class kafka.tier.state.FileTierPartitionState
 
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

throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
 
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
 
TierAbortedTxnReader - Class in kafka.tier.fetcher
 
TierAbortedTxnReader() - Constructor for class kafka.tier.fetcher.TierAbortedTxnReader
 
tieredSegments(NavigableSet<Long>, TierPartitionState, Optional<TierObjectStore>) - Static method in class kafka.tier.state.TierUtils
 
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.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 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(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) - 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(Records, 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
 
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.FileType - Enum in kafka.tier.store
 
TierObjectStore.ObjectMetadata - Class in kafka.tier.store
 
TierObjectStoreConfig - Class in kafka.tier.store
 
TierObjectStoreConfig(String, KafkaConfig) - Constructor for class kafka.tier.store.TierObjectStoreConfig
 
TierObjectStoreConfig(String, Integer) - Constructor for class kafka.tier.store.TierObjectStoreConfig
 
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
 
TierObjectStoreUtils - Class in kafka.tier.store
 
TierObjectStoreUtils() - Constructor for class kafka.tier.store.TierObjectStoreUtils
 
TierPartitionDeleteComplete - Class in kafka.tier.domain
 
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
 
TierPartitionDeleteInitiate(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
 
TierPartitionDeleteInitiate(TopicIdPartition, PartitionDeleteInitiate) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
 
TierPartitionState - Interface in kafka.tier.state
 
TierPartitionState.AppendResult - Enum in kafka.tier.state
The result of an attempt to append a tier metadata entry.
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
 
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
 
TierPartitionStatus - Enum in kafka.tier.state
 
TierRecordType - Enum in kafka.tier.domain
 
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
 
TierSegmentDeleteComplete(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
 
TierSegmentDeleteComplete(TopicIdPartition, SegmentDeleteComplete) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
 
TierSegmentDeleteInitiate - Class in kafka.tier.domain
 
TierSegmentDeleteInitiate(TopicIdPartition, int, UUID) - 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
 
TierSegmentUploadComplete(TopicIdPartition, int, UUID) - 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
 
TierSegmentUploadInitiate(TopicIdPartition, int, UUID, long, long, long, int, boolean, boolean, boolean) - 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
 
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, Supplier<AdminZkClient>) - 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) - Constructor for class kafka.tier.topic.TierTopicConsumer
 
TierTopicConsumer(TierTopicManagerConfig, Supplier<Consumer<byte[], byte[]>>, Supplier<Consumer<byte[], byte[]>>, TierTopicManagerCommitter) - 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
 
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>, Metrics) - 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, HashMap<TopicIdPartition, Long>) - 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
 
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.
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
 
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.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 - 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
 
toState(byte) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
 
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.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.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.TierSegmentReader.NextOffsetAndBatchMetadata
 
toString() - Method in class kafka.tier.state.FileTierPartitionState
 
toString() - Method in class kafka.tier.state.Header
 
toString() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
 
toString() - Method in class kafka.tier.TierTimestampAndOffset
 
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
 
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.
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.
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.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
 
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(Integer, Long) - Method in class kafka.tier.TierTopicManagerCommitter
Update position materialized by the TierTopicManager consumer.
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

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.
VALIDATOR - Static variable in class kafka.common.TopicPlacement
 
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.TierPartitionStatus
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.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.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.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.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.ObjectMetadata
 

W

workDir - Variable in class kafka.tier.tools.TierMetadataValidator
 
WORKING_DIR - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
WORKING_DIR_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
 
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.PartitionDeleteComplete
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__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.PartitionDeleteComplete
 
__init(int, ByteBuffer) - Method in class kafka.tier.serdes.PartitionDeleteInitiate
 
__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 K L M N O P R S T U V W _ 
Skip navigation links