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

A

AbstractTierMetadata - Class in kafka.tier.domain
 
AbstractTierMetadata() - Constructor for class kafka.tier.domain.AbstractTierMetadata
 
addBrokerId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
addEndOffsetDelta(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addHasAborts(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addHasEpochState(FlatBufferBuilder, boolean) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addLastStableOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addListener(TierMetadataManager.ChangeListener) - Method in class kafka.tier.TierMetadataManager
Register a change listener.
addMaxTimestamp(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
addMessageId(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addMetadata(AbstractTierMetadata) - Method in class kafka.tier.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.
addSize(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addStartOffset(FlatBufferBuilder, long) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addState(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.ObjectMetadata
 
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.ObjectMetadata
 
addTierEpoch(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.InitLeader
 
addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.ObjectMetadata
 
addVersion(FlatBufferBuilder, byte) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
append(AbstractTierMetadata) - Method in class kafka.tier.state.FileTierPartitionState
 
append(AbstractTierMetadata) - Method in class kafka.tier.state.MemoryTierPartitionState
 
append(AbstractTierMetadata) - Method in interface kafka.tier.state.TierPartitionState
Appends abstract metadata to the tier partition.
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 - Static variable in class kafka.tier.serdes.State
 
available() - Method in class kafka.tier.store.AutoAbortingS3InputStream
 

B

becomeArchiver(TopicPartition, int) - Method in class kafka.tier.TierTopicManager
Performs a write to the tier topic to attempt to become leader for the tiered topic partition.
becomeFollower(TopicPartition) - Method in class kafka.tier.TierMetadataManager
Called when replica becomes follower.
becomeLeader(TopicPartition, int) - Method in class kafka.tier.TierMetadataManager
Called when replica is elected to be the leader.
becomeReady(String) - Method in class kafka.tier.TierTopicManager
Ensure tier topic has been created and setup the backing consumer and producer before signalling ready.
beginCatchup() - Method in class kafka.tier.state.FileTierPartitionState
 
beginCatchup() - Method in class kafka.tier.state.MemoryTierPartitionState
 
beginCatchup() - Method in interface kafka.tier.state.TierPartitionState
Begin catchup phase for tier partition state.
bootstrapServers - Variable in class kafka.tier.TierTopicManagerConfig
 
brokerId() - Method in class kafka.tier.domain.TierTopicInitLeader
 
brokerId() - Method in class kafka.tier.serdes.InitLeader
 
brokerId - Variable in class kafka.tier.TierTopicManagerConfig
 

C

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.
catchingUp() - Method in class kafka.tier.TierTopicManager
 
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 class kafka.tier.state.MemoryTierPartitionState
 
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.MockInMemoryTierObjectStore
 
close() - Method in class kafka.tier.store.S3TierObjectStore
 
close() - Method in interface kafka.tier.store.TierObjectStore
 
close() - Method in class kafka.tier.TierMetadataManager
 
closeHandlers() - Method in class kafka.tier.state.FileTierPartitionState
 
closeHandlers() - Method in class kafka.tier.state.MemoryTierPartitionState
 
closeHandlers() - Method in interface kafka.tier.state.TierPartitionState
 
clusterId - Variable in class kafka.tier.TierTopicManagerConfig
 
commitIntervalMs - Variable in class kafka.tier.TierTopicManagerConfig
 
committedEndOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
committedEndOffset() - Method in class kafka.tier.state.MemoryTierPartitionState
 
committedEndOffset() - Method in interface kafka.tier.state.TierPartitionState
Return the end offset spanned by the TierPartitionState that has been committed to disk.
completeExceptionally(TopicPartition, Exception) - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
Complete a TimestampAndOffset request exceptionally.
ConsumerBuilder - Class in kafka.tier.client
 
ConsumerBuilder(TierTopicManagerConfig) - Constructor for class kafka.tier.client.ConsumerBuilder
 
createTierPartitionStateHeader(FlatBufferBuilder, byte, int, byte) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
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 class kafka.tier.state.MemoryTierPartitionState
 
delete() - Method in interface kafka.tier.state.TierPartitionState
Delete this TierPartitionState from local storage.
delete(TopicPartition) - Method in class kafka.tier.TierMetadataManager
Delete tier metadata for given topic partition.
DELETED - Static variable in class kafka.tier.serdes.State
 
deserialize(byte[], byte[]) - Static method in class kafka.tier.domain.AbstractTierMetadata
Deserializes byte key and value read from Tier Topic into Tier Metadata.
dir() - Method in class kafka.tier.state.FileTierPartitionState
 
dir() - Method in class kafka.tier.state.MemoryTierPartitionState
 
dir() - Method in interface kafka.tier.state.TierPartitionState
The directory where the TierPartition is stored on disk.
doDelete(List<String>, AdminClient) - Method in class kafka.tools.StreamsResetter
 
doWork() - Method in class kafka.tier.TierTopicManager
Work cycle public for testing purposes.
DumpTierPartitionState - Class in kafka.tier.tools
 
DumpTierPartitionState() - Constructor for class kafka.tier.tools.DumpTierPartitionState
 

E

emptyFetchResult() - Static method in class kafka.tier.fetcher.TierFetchResult
 
endInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
 
endObjectMetadata(FlatBufferBuilder) - Static method in class kafka.tier.serdes.ObjectMetadata
 
endOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
endOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
endOffset() - Method in class kafka.tier.state.MemoryTierPartitionState
 
endOffset() - Method in interface kafka.tier.state.TierPartitionState
Return the uncommitted end offset spanned by the TierPartitionState.
endOffsetDelta() - Method in class kafka.tier.domain.TierObjectMetadata
 
endOffsetDelta() - Method in class kafka.tier.serdes.ObjectMetadata
 
endTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
ensureTopicCreated(String, String, int, short) - Static method in class kafka.tier.topic.TierTopicAdmin
Create Tier Topic if one does not exist.
epochIfLeader() - Method in class kafka.tier.TierMetadataManager.PartitionMetadata
 
equals(Object) - Method in class kafka.tier.domain.TierObjectMetadata
 
equals(Object) - Method in class kafka.tier.domain.TierTopicInitLeader
 
equals(Object) - Method in class kafka.tier.TierTimestampAndOffset
 
exception - Variable in class kafka.tier.fetcher.TierFetchResult
 

F

fetch(List<TierFetchMetadata>, Consumer<DelayedOperationKey>) - Method in class kafka.tier.fetcher.TierFetcher
Execute a read for a single partition from Tiered Storage.
fetchLeaderEpochState(TierObjectMetadata) - 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.
fetchOffsetForTimestamp(Map<TopicPartition, TierTimestampAndOffset>, Optional<IsolationLevel>, Consumer<DelayedOperationKey>) - Method in class kafka.tier.fetcher.TierFetcher
 
FileTierPartitionIterator - Class in kafka.tier.state
 
FileTierPartitionIterator(TopicPartition, 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
 
FileTierPartitionStateFactory - Class in kafka.tier.state
 
FileTierPartitionStateFactory() - Constructor for class kafka.tier.state.FileTierPartitionStateFactory
 
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
 
finishObjectMetadataBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.ObjectMetadata
 
finishSizePrefixedInitLeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.InitLeader
 
finishSizePrefixedObjectMetadataBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.ObjectMetadata
 
finishSizePrefixedTierPartitionStateHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
finishTierPartitionStateHeaderBuffer(FlatBufferBuilder, int) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
flush() - Method in class kafka.tier.state.FileTierPartitionState
 
flush() - Method in class kafka.tier.state.MemoryTierPartitionState
 
flush() - Method in interface kafka.tier.state.TierPartitionState
flush data contained in this TierPartitionState to disk.
flush() - 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

getDateTime(String) - Method in class kafka.tools.StreamsResetter
 
getInputStream() - Method in interface kafka.tier.store.TierObjectStoreResponse
 
getObject(TierObjectMetadata, TierObjectStore.TierObjectStoreFileType, Integer, Integer) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
getObject(TierObjectMetadata, TierObjectStore.TierObjectStoreFileType, Integer, Integer) - Method in class kafka.tier.store.S3TierObjectStore
 
getObject(TierObjectMetadata, TierObjectStore.TierObjectStoreFileType, Integer, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectMetadata, TierObjectStore.TierObjectStoreFileType, Integer) - Method in interface kafka.tier.store.TierObjectStore
 
getObject(TierObjectMetadata, TierObjectStore.TierObjectStoreFileType) - Method in interface kafka.tier.store.TierObjectStore
 
getObjectSize() - Method in interface kafka.tier.store.TierObjectStoreResponse
 
getRootAsInitLeader(ByteBuffer) - Static method in class kafka.tier.serdes.InitLeader
 
getRootAsInitLeader(ByteBuffer, InitLeader) - Static method in class kafka.tier.serdes.InitLeader
 
getRootAsObjectMetadata(ByteBuffer) - Static method in class kafka.tier.serdes.ObjectMetadata
 
getRootAsObjectMetadata(ByteBuffer, ObjectMetadata) - Static method in class kafka.tier.serdes.ObjectMetadata
 
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
 
getSuffix() - Method in enum kafka.tier.store.TierObjectStore.TierObjectStoreFileType
 

H

hasAborts() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasAborts() - Method in class kafka.tier.serdes.ObjectMetadata
 
hasEpochState() - Method in class kafka.tier.domain.TierObjectMetadata
 
hasEpochState() - Method in class kafka.tier.serdes.ObjectMetadata
 
hashCode() - Method in class kafka.tier.domain.TierObjectMetadata
 
hashCode() - Method in class kafka.tier.domain.TierTopicInitLeader
 
hashCode() - Method in class kafka.tier.TierTimestampAndOffset
 

I

ID - Static variable in class kafka.tier.domain.TierObjectMetadata
 
ID - Static variable in class kafka.tier.domain.TierTopicInitLeader
 
InitLeader - Class in kafka.tier.serdes
 
InitLeader() - Constructor for class kafka.tier.serdes.InitLeader
 
initState(File, TopicPartition, boolean) - Method in class kafka.tier.state.FileTierPartitionStateFactory
 
initState(File, TopicPartition, boolean) - Method in class kafka.tier.state.MemoryTierPartitionStateFactory
 
initState(File, TopicPartition, boolean) - Method in interface kafka.tier.state.TierPartitionStateFactory
 
initState(TopicPartition, File, LogConfig) - Method in class kafka.tier.TierMetadataManager
Initialize tier state for given topic partition.
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
 
isOpen() - Method in enum kafka.tier.state.TierPartitionStatus
 
isOpenForWrite() - Method in enum kafka.tier.state.TierPartitionStatus
 
isReady() - Method in class kafka.tier.TierTopicManager
Return whether TierTopicManager is ready to accept writes.
iterator(TopicPartition, FileChannel) - Static method in class kafka.tier.state.FileTierPartitionState
 

K

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

L

lastStableOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
lastStableOffset() - Method in class kafka.tier.serdes.ObjectMetadata
 
leaderEpoch() - Method in class kafka.tier.TierTimestampAndOffset
 
leastSignificantBits() - Method in class kafka.tier.serdes.UUID
 
loadRecords(CancellationContext, InputStream, int, long, long) - Static method in class kafka.tier.fetcher.TierSegmentReader
Loads records from a given InputStream up to maxBytes.
logDirs - Variable in class kafka.tier.TierTopicManagerConfig
 

M

main(String[]) - Static method in class kafka.tier.tools.DumpTierPartitionState
 
main(String[]) - Static method in class kafka.tools.StreamsResetter
 
makeNext() - Method in class kafka.tier.state.FileTierPartitionIterator
 
materializationListener(long) - Method in class kafka.tier.state.FileTierPartitionState
 
materializationListener(long) - Method in class kafka.tier.state.MemoryTierPartitionState
 
materializationListener(long) - Method in interface kafka.tier.state.TierPartitionState
Sets up a listener for this tier partition state for use by the replica fetcher.
materializeUntilOffset(TopicPartition, Long) - Method in class kafka.tier.TierMetadataManager
 
maxTimestamp() - Method in class kafka.tier.domain.TierObjectMetadata
 
maxTimestamp() - Method in class kafka.tier.serdes.ObjectMetadata
 
maybeSeekToEnd(String, Consumer<byte[], byte[]>, Set<TopicPartition>) - Method in class kafka.tools.StreamsResetter
 
MemoryTierPartitionState - Class in kafka.tier.state
 
MemoryTierPartitionState(File, TopicPartition, boolean) - Constructor for class kafka.tier.state.MemoryTierPartitionState
 
MemoryTierPartitionStateFactory - Class in kafka.tier.state
 
MemoryTierPartitionStateFactory() - Constructor for class kafka.tier.state.MemoryTierPartitionStateFactory
 
messageId() - Method in class kafka.tier.domain.TierObjectMetadata
Random ID associated with each TierObjectMetadata entry.
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.ObjectMetadata
 
messageId(UUID) - Method in class kafka.tier.serdes.ObjectMetadata
 
metadata(long) - Method in class kafka.tier.state.FileTierPartitionState
 
metadata(long) - Method in class kafka.tier.state.MemoryTierPartitionState
 
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
 
MockInMemoryTierObjectStore - Class in kafka.tier.store
 
MockInMemoryTierObjectStore(TierObjectStoreConfig) - Constructor for class kafka.tier.store.MockInMemoryTierObjectStore
 
mostSignificantBits() - Method in class kafka.tier.serdes.UUID
 
mutateEndOffsetDelta(int) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateHasAborts(boolean) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateHasEpochState(boolean) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateLastStableOffset(long) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateMaxTimestamp(long) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateSize(int) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateStartOffset(long) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateState(byte) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateStatus(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateTierEpoch(int) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateTierEpoch(int) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
mutateVersion(byte) - Method in class kafka.tier.serdes.ObjectMetadata
 
mutateVersion(byte) - Method in class kafka.tier.serdes.TierPartitionStateHeader
 

N

name(int) - Static method in class kafka.tier.serdes.State
 
names - Static variable in class kafka.tier.serdes.State
 
newContext() - Static method in class kafka.tier.fetcher.CancellationContext
Create a new root CancellationContext.
numFetchThreads - Variable in class kafka.tier.fetcher.TierFetcherConfig
 
numPartitions - Variable in class kafka.tier.TierTopicManagerConfig
 
numSegments() - Method in class kafka.tier.state.FileTierPartitionState
 
numSegments() - Method in class kafka.tier.state.MemoryTierPartitionState
 
numSegments() - Method in interface kafka.tier.state.TierPartitionState
Scan the ObjectMetadata (segment) entries in this tier partition, and return the count.

O

objectMetadata() - Method in class kafka.tier.domain.TierObjectMetadata
 
ObjectMetadata - Class in kafka.tier.serdes
 
ObjectMetadata() - Constructor for class kafka.tier.serdes.ObjectMetadata
 
offsetForTimestamp(CancellationContext, InputStream, long) - Static method in class kafka.tier.fetcher.TierSegmentReader
Read the supplied input stream to find the first offset with a timestamp >= targetTimestamp
onBecomeFollower(TopicPartition) - Method in interface kafka.tier.TierMetadataManager.ChangeListener
Fired when this topic partition becomes follower.
onBecomeLeader(TopicPartition, int) - Method in interface kafka.tier.TierMetadataManager.ChangeListener
Fired when this topic partition becomes leader.
onCatchUpComplete() - Method in class kafka.tier.state.FileTierPartitionState
 
onCatchUpComplete() - Method in class kafka.tier.state.MemoryTierPartitionState
 
onCatchUpComplete() - Method in interface kafka.tier.state.TierPartitionState
Mark catchup completed for tier partition state.
onConfigChange(TopicPartition, LogConfig) - Method in class kafka.tier.TierMetadataManager
Called when log configuration for a topic partition is changed.
onDelete(TopicPartition) - Method in interface kafka.tier.TierMetadataManager.ChangeListener
Fired when this topic partition is deleted.
onTieringEnable() - Method in class kafka.tier.state.FileTierPartitionState
 
onTieringEnable() - Method in class kafka.tier.state.MemoryTierPartitionState
 
onTieringEnable() - Method in interface kafka.tier.state.TierPartitionState
Called when tiering is enabled for this tier topic partition.

P

partitionId(TopicPartition) - Method in class kafka.tier.topic.TierTopicPartitioner
Determine the Tier Topic partitionId that should contain metadata for a given tiered TopicPartition
partitionState(TopicPartition) - Method in class kafka.tier.TierTopicManager
Return the TierPartitionState for a given topic partition.
path() - Method in class kafka.tier.state.FileTierPartitionState
 
path() - Method in class kafka.tier.state.MemoryTierPartitionState
 
path() - Method in interface kafka.tier.state.TierPartitionState
Path to where the TierPartition is stored on disk.
payloadBuffer() - Method in class kafka.tier.domain.AbstractTierMetadata
 
payloadBuffer() - Method in class kafka.tier.domain.TierObjectMetadata
 
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.TierTopicManagerConfig
 
position() - Method in class kafka.tier.state.FileTierPartitionIterator
 
positions() - Method in class kafka.tier.TierTopicManagerCommitter
 
ProducerBuilder - Class in kafka.tier.client
 
ProducerBuilder(TierTopicManagerConfig) - Constructor for class kafka.tier.client.ProducerBuilder
 
putSegment(TierObjectMetadata, File, File, File, File, File, Optional<File>) - Method in class kafka.tier.store.MockInMemoryTierObjectStore
 
putSegment(TierObjectMetadata, File, File, File, File, File, Optional<File>) - Method in class kafka.tier.store.S3TierObjectStore
 
putSegment(TierObjectMetadata, File, File, File, File, File, 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) - Static method in class kafka.tier.fetcher.TierSegmentReader
Reads one full batch from an InputStream.
readBatchInto(InputStream, ByteBuffer) - Static method in class kafka.tier.fetcher.TierSegmentReader
Similar to readBatch(), this method reads a full RecordBatch.
records - Variable in class kafka.tier.fetcher.TierFetchResult
 
replicationFactor - Variable in class kafka.tier.TierTopicManagerConfig
 
requestTimeoutMs - Variable in class kafka.tier.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.TierTopicManager
tier topic manager work loop
run() - Method in class kafka.tier.TierTopicManagerCommitter
Main work loop.
run(String[]) - Method in class kafka.tools.StreamsResetter
 
run(String[], Properties) - Method in class kafka.tools.StreamsResetter
 

S

s3AwsAccessKeyId - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3AwsSecretAccessKey - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3bucket - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3EndpointOverride - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3MultipartUploadSize - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3Region - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3SignerOverride - Variable in class kafka.tier.store.TierObjectStoreConfig
 
s3SseAlgorithm - Variable in class kafka.tier.store.TierObjectStoreConfig
 
S3TierObjectStore - Class in kafka.tier.store
 
S3TierObjectStore(TierObjectStoreConfig) - Constructor for class kafka.tier.store.S3TierObjectStore
 
segmentOffsets() - Method in class kafka.tier.state.FileTierPartitionState
 
segmentOffsets(long, long) - Method in class kafka.tier.state.FileTierPartitionState
 
segmentOffsets() - Method in class kafka.tier.state.MemoryTierPartitionState
 
segmentOffsets(long, long) - Method in class kafka.tier.state.MemoryTierPartitionState
 
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.
serializeKey() - Method in class kafka.tier.domain.AbstractTierMetadata
 
serializeValue() - Method in class kafka.tier.domain.AbstractTierMetadata
 
setupConsumer(String, String, String) - Method in class kafka.tier.client.ConsumerBuilder
Setup the internal kafka consumer for the tier topic manager.
setupConsumer(String, String, String) - Method in interface kafka.tier.client.TierTopicConsumerBuilder
 
setupProducer(String) - Method in class kafka.tier.client.ProducerBuilder
Setup the internal kafka producer for the tier topic manager.
setupProducer(String) - Method in interface kafka.tier.client.TierTopicProducerBuilder
 
shiftOffsetsBy(Consumer<byte[], byte[]>, Set<TopicPartition>, long) - Method in class kafka.tools.StreamsResetter
 
shutdown() - Method in class kafka.tier.TierTopicManager
Shutdown the tier topic manager.
shutdown() - Method in class kafka.tier.TierTopicManagerCommitter
Initiate shutdown.
size() - Method in class kafka.tier.domain.TierObjectMetadata
 
size() - Method in class kafka.tier.serdes.ObjectMetadata
 
skip(long) - Method in class kafka.tier.store.AutoAbortingS3InputStream
 
startInitLeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.InitLeader
 
startObjectMetadata(FlatBufferBuilder) - Static method in class kafka.tier.serdes.ObjectMetadata
 
startOffset() - Method in class kafka.tier.domain.TierObjectMetadata
 
startOffset() - Method in class kafka.tier.serdes.ObjectMetadata
 
startOffset() - Method in class kafka.tier.state.FileTierPartitionState
 
startOffset() - Method in class kafka.tier.state.MemoryTierPartitionState
 
startOffset() - Method in interface kafka.tier.state.TierPartitionState
Determine start offset spanned by the TierPartitionState.
startTierPartitionStateHeader(FlatBufferBuilder) - Static method in class kafka.tier.serdes.TierPartitionStateHeader
 
startup() - Method in class kafka.tier.TierTopicManager
Startup the tier topic manager.
state() - Method in class kafka.tier.domain.TierObjectMetadata
 
state() - Method in class kafka.tier.serdes.ObjectMetadata
 
State - Class in kafka.tier.serdes
 
status() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
status() - Method in class kafka.tier.state.FileTierPartitionState
 
status() - Method in class kafka.tier.state.MemoryTierPartitionState
 
status() - Method in interface kafka.tier.state.TierPartitionState
Return the current status of the TierPartitionState.
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.

T

tierEnabledPartitionStateIterator() - Method in class kafka.tier.TierMetadataManager
Get an iterator over states for all topic partitions for which tiering is enabled.
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.TierTopicInitLeader
 
tierEpoch() - Method in class kafka.tier.serdes.InitLeader
 
tierEpoch() - Method in class kafka.tier.serdes.ObjectMetadata
 
tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 
tierEpoch() - Method in class kafka.tier.state.FileTierPartitionState
 
tierEpoch() - Method in class kafka.tier.state.MemoryTierPartitionState
 
tierEpoch() - Method in interface kafka.tier.state.TierPartitionState
Return the current tierEpoch.
TierFetcher - Class in kafka.tier.fetcher
 
TierFetcher(TierFetcherConfig, TierObjectStore, 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) - 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, Throwable) - Constructor for class kafka.tier.fetcher.TierFetchResult
 
tieringEnabled() - Method in class kafka.tier.state.FileTierPartitionState
 
tieringEnabled() - Method in class kafka.tier.state.MemoryTierPartitionState
 
tieringEnabled() - Method in interface kafka.tier.state.TierPartitionState
 
tieringEnabled() - Method in class kafka.tier.TierMetadataManager.PartitionMetadata
 
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
 
TierMetadataManager - Class in kafka.tier
Central place to maintain lifecycle of partitions for tiered storage.
TierMetadataManager(TierPartitionStateFactory, Option<TierObjectStore>, LogDirFailureChannel, boolean) - Constructor for class kafka.tier.TierMetadataManager
 
TierMetadataManager.ChangeListener - Interface in kafka.tier
Interface to register callbacks on the lifecycle of tiering enabled topic partitions.
TierMetadataManager.PartitionMetadata - Class in kafka.tier
Tiering metadata for a particular topic-partition.
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
 
tierNamespace - Variable in class kafka.tier.TierTopicManagerConfig
 
TierObjectMetadata - Class in kafka.tier.domain
 
TierObjectMetadata(TopicPartition, ObjectMetadata) - Constructor for class kafka.tier.domain.TierObjectMetadata
 
TierObjectMetadata(TopicPartition, int, long, int, long, long, int, boolean, boolean, byte) - Constructor for class kafka.tier.domain.TierObjectMetadata
 
TierObjectStore - Interface in kafka.tier.store
 
tierObjectStore() - Method in class kafka.tier.TierMetadataManager
Get the tier object store handle.
TierObjectStore.TierObjectStoreFileType - Enum in kafka.tier.store
 
TierObjectStoreConfig - Class in kafka.tier.store
 
TierObjectStoreConfig(KafkaConfig) - Constructor for class kafka.tier.store.TierObjectStoreConfig
 
TierObjectStoreConfig() - Constructor for class kafka.tier.store.TierObjectStoreConfig
 
TierObjectStoreFatalException - Exception in kafka.tier.exceptions
 
TierObjectStoreFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
 
TierObjectStoreFatalException(Throwable) - 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(Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
 
tierPartitionMetadata(TopicPartition) - Method in class kafka.tier.TierMetadataManager
Retrieve the partition metadata, if present.
TierPartitionState - Interface in kafka.tier.state
 
tierPartitionState() - Method in class kafka.tier.TierMetadataManager.PartitionMetadata
 
tierPartitionState(TopicPartition) - Method in class kafka.tier.TierMetadataManager
Retrieve the tier partition state for a particular topic partition, if present.
TierPartitionState.AppendResult - Enum in kafka.tier.state
The result of an attempt to append a tier metadata entry.
TierPartitionStateFactory - Interface in kafka.tier.state
 
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
 
tierProducer(String) - Static method in class kafka.tier.client.ProducerBuilder
 
TierRecordType - Enum in kafka.tier.domain
 
TierSegmentReader - Class in kafka.tier.fetcher
 
TierSegmentReader() - Constructor for class kafka.tier.fetcher.TierSegmentReader
 
TierStateFetcher - Class in kafka.tier.fetcher
 
TierStateFetcher(Integer, TierObjectStore) - Constructor for class kafka.tier.fetcher.TierStateFetcher
 
TierTimestampAndOffset - Class in kafka.tier
 
TierTimestampAndOffset(long, TierObjectMetadata) - Constructor for class kafka.tier.TierTimestampAndOffset
 
tierTimestampAndOffsets() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
TierTimestampAndOffsets that will be resolved by this fetch
TierTopicAdmin - Class in kafka.tier.topic
 
TierTopicAdmin() - Constructor for class kafka.tier.topic.TierTopicAdmin
 
TierTopicConsumerBuilder - Interface in kafka.tier.client
 
TierTopicInitLeader - Class in kafka.tier.domain
 
TierTopicInitLeader(TopicPartition, int, UUID, int) - Constructor for class kafka.tier.domain.TierTopicInitLeader
 
TierTopicInitLeader(TopicPartition, InitLeader) - Constructor for class kafka.tier.domain.TierTopicInitLeader
 
TierTopicManager - Class in kafka.tier
A metadata store for tiered storage.
TierTopicManager(TierTopicManagerConfig, TierTopicConsumerBuilder, TierTopicProducerBuilder, Supplier<String>, TierMetadataManager) - Constructor for class kafka.tier.TierTopicManager
Instantiate TierTopicManager.
TierTopicManager(TierMetadataManager, TierTopicManagerConfig, Supplier<String>, Metrics) - Constructor for class kafka.tier.TierTopicManager
Primary public constructor for TierTopicManager.
TierTopicManagerCommitter - Class in kafka.tier
 
TierTopicManagerConfig - Class in kafka.tier
 
TierTopicManagerConfig(String, String, short, short, int, String, Long, Integer, Integer, List<String>) - Constructor for class kafka.tier.TierTopicManagerConfig
 
TierTopicManagerConfig(KafkaConfig, String) - Constructor for class kafka.tier.TierTopicManagerConfig
 
TierTopicPartitioner - Class in kafka.tier.topic
 
TierTopicPartitioner(int) - Constructor for class kafka.tier.topic.TierTopicPartitioner
 
TierTopicProducerBuilder - Interface in kafka.tier.client
 
timestamp - Variable in class kafka.tier.TierTimestampAndOffset
 
timestamp() - Method in class kafka.tier.TierTimestampAndOffset
 
toByte(TierPartitionStatus) - Static method in enum kafka.tier.state.TierPartitionStatus
 
topicName(String) - Static method in class kafka.tier.TierTopicManager
Generate the tier topic name, namespaced if tierNamespace is non-empty.
topicPartition() - Method in class kafka.tier.domain.AbstractTierMetadata
Topic-partition corresponding to this tier metadata.
topicPartition() - Method in class kafka.tier.domain.TierObjectMetadata
 
topicPartition() - Method in class kafka.tier.domain.TierTopicInitLeader
 
topicPartition() - Method in class kafka.tier.state.FileTierPartitionState
 
topicPartition() - Method in class kafka.tier.state.MemoryTierPartitionState
 
topicPartition() - Method in interface kafka.tier.state.TierPartitionState
The topic-partition corresponding to this TierPartition.
toString() - Method in class kafka.tier.domain.TierObjectMetadata
 
toString() - Method in class kafka.tier.domain.TierTopicInitLeader
 
toString() - Method in class kafka.tier.TierTimestampAndOffset
 
totalSize() - Method in class kafka.tier.state.FileTierPartitionState
 
totalSize() - Method in class kafka.tier.state.MemoryTierPartitionState
 
totalSize() - Method in interface kafka.tier.state.TierPartitionState
Sum the size of all segment spanned by this TierPartitionState.
type() - Method in class kafka.tier.domain.AbstractTierMetadata
 
type() - Method in class kafka.tier.domain.TierObjectMetadata
 
type() - Method in class kafka.tier.domain.TierTopicInitLeader
 

U

updateDir(File) - Method in class kafka.tier.state.FileTierPartitionState
 
updateDir(File) - Method in class kafka.tier.state.MemoryTierPartitionState
 
updateDir(File) - Method in interface kafka.tier.state.TierPartitionState
Update the directory reference for the log and indices in this segment.
updatePosition(Integer, Long) - Method in class kafka.tier.TierTopicManagerCommitter
Update position materialized by the TierTopicManager consumer.
UUID - Class in kafka.tier.serdes
 
UUID() - Constructor for class kafka.tier.serdes.UUID
 

V

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.TierObjectStoreFileType
Returns the enum constant of this type with the specified name.
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.TierObjectStoreFileType
Returns an array containing the constants of this enum type, in the order they are declared.
version() - Method in class kafka.tier.domain.TierObjectMetadata
 
version() - Method in class kafka.tier.domain.TierTopicInitLeader
 
version() - Method in class kafka.tier.serdes.InitLeader
 
version() - Method in class kafka.tier.serdes.ObjectMetadata
 
version() - Method in class kafka.tier.serdes.TierPartitionStateHeader
 

_

__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.InitLeader
 
__assign(int, ByteBuffer) - Method in class kafka.tier.serdes.ObjectMetadata
 
__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.ObjectMetadata
 
__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 _ 
Skip navigation links