- CachedFetchOffsetMetadata - Class in kafka.tier.fetcher.offsetcache
-
- CachedFetchOffsetMetadata(FetchOffsetMetadata, long) - Constructor for class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
-
- cancel() - Method in class kafka.tier.fetcher.CancellationContext
-
Cancel this CancellationContext, causing all
sub-CancellationContexts to cancel.
- cancel() - Method in class kafka.tier.fetcher.PendingFetch
-
Cancel the pending fetch.
- cancel() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
Cancel the request
- CancellationContext - Class in kafka.tier.fetcher
-
A tree to notify processes of cancellation in a thread safe way.
- cancelTracked(AbstractTierMetadata) - Method in class kafka.tier.topic.TierTopicConsumer
-
Cancel materialization tracking for provided metadata.
- canTransitionTo(TierObjectMetadata.State) - Method in enum kafka.tier.domain.TierObjectMetadata.State
-
Check if we can safely transition to the given state.
- choice() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- cleanup() - Method in class kafka.tier.topic.TierTopicConsumer
-
- client(S3TierObjectStoreConfig) - Static method in class kafka.tier.store.S3TierObjectStore
-
- clientId(String, int, long) - Static method in class kafka.tier.client.TierTopicProducerSupplier
-
- clientIdPrefix(String) - Static method in class kafka.tier.client.TierTopicClient
-
Client id prefix to use for tier topic clients.
- close() - Method in class kafka.tier.fetcher.CancellationContext
-
- close() - Method in class kafka.tier.fetcher.MemoryTracker
-
- close() - Method in class kafka.tier.fetcher.TierFetcher
-
Seal the TierFetcher from accepting new fetches, and cancel all in-progress fetches.
- close() - Method in class kafka.tier.fetcher.TierStateFetcher
-
- close() - Method in class kafka.tier.state.FileTierPartitionState
-
- close() - Method in interface kafka.tier.state.TierPartitionState
-
Close TierPartition, flushing to disk.
- close() - Method in class kafka.tier.store.AutoAbortingS3InputStream
-
- close() - Method in class kafka.tier.store.GcsTierObjectStore
-
- close() - Method in class kafka.tier.store.MockInMemoryTierObjectStore
-
- close() - Method in class kafka.tier.store.S3TierObjectStore
-
- close() - Method in interface kafka.tier.store.TierObjectStore
-
- close() - Method in interface kafka.tier.store.TierObjectStoreResponse
-
- close() - Method in class kafka.tier.tools.TierMetadataComparator
-
As part of the closeable contract, this method will cleanup all the open resources such as backend stores
as well as cancel any long-running existing verification tasks
- close() - Method in class kafka.tier.tools.TierMetadataValidator
-
This method will be primarily used to clean up resources including various backends
- close() - Method in class kafka.tier.topic.TierMessageFormatter
-
- closeHandlers() - Method in class kafka.tier.state.FileTierPartitionState
-
- closeHandlers() - Method in interface kafka.tier.state.TierPartitionState
-
- CLUSTER_ID - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- CLUSTER_ID_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- clusterId - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- clusterIdOpt - Variable in class kafka.tier.store.TierObjectStoreConfig
-
- commitIntervalMs - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- commitPositions(Iterator<TierPartitionState>) - Method in class kafka.tier.topic.TierTopicConsumer
-
Commit positions for the provided tier partition states.
- committedEndOffset() - Method in class kafka.tier.state.FileTierPartitionState
-
- committedEndOffset() - Method in interface kafka.tier.state.TierPartitionState
-
Return the end offset spanned by the TierPartitionState that has been committed to disk.
- ComparatorInfo - Class in kafka.tier.tools.common
-
This class will act as a placeholder class for all the DAOs that will be used by TierMetadataComparator tool
All of the inner classes follow the specific pattern in terms of accessors:
1.
- ComparatorInfo.ComparatorOutput - Class in kafka.tier.tools.common
-
This class represents a single output from the Comparator tool
For every fenced topic partition details, we would generate one such distinct output object
- ComparatorInfo.ComparatorReplicaInfo - Class in kafka.tier.tools.common
-
This class represents the replica info which is the core unit of the comparator tool
For every n fenced topic details and m bootstrap server, there should be n*(m+1) replicas
The +1 is because we would also generate one replica directly from rematerialized events
- ComparatorOutput(Map<String, ComparatorInfo.ComparatorReplicaInfo>, ComparatorInfo.ComparatorReplicaInfo, FenceEventInfo) - Constructor for class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- ComparatorReplicaInfo(String, Path, TopicIdPartition) - Constructor for class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- ComparatorReplicaInfo(String, String, String, boolean) - Constructor for class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- comparesStates(Path, Path) - Method in class kafka.tier.tools.TierMetadataValidator
-
Compares the 'actual' state file with 'expected' state file.
- COMPARISON_TOOL_INPUT - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_INPUT_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_OUTPUT - Static variable in class kafka.tier.tools.RecoveryUtils
-
- COMPARISON_TOOL_OUTPUT_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- completeCatchup() - Method in interface kafka.tier.topic.TierTopicConsumer.ClientCtx
-
- completeExceptionally(TopicPartition, Exception) - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
Complete a TimestampAndOffset request exceptionally.
- configure(Map<String, ?>) - Method in class kafka.metrics.KafkaYammerMetrics
-
- configuredNumPartitions - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- configuredReplicationFactor - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- constraints() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- consumer - Variable in class kafka.tier.tools.TierTopicMaterializationUtils
-
- contentHash() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- contentHash() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- contentHashAsByteBuffer() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- contentHashInByteBuffer(ByteBuffer) - Method in class kafka.tier.serdes.PartitionForceRestore
-
- controllerEpoch() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- count() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- createEmpty() - Static method in class kafka.tier.store.TierObjectStoreConfig
-
- createMaterializationTrackingInfo(FlatBufferBuilder, long, long, int, int) - Static method in class kafka.tier.serdes.MaterializationTrackingInfo
-
- createOffsetAndEpoch(FlatBufferBuilder, long, int) - Static method in class kafka.tier.serdes.OffsetAndEpoch
-
- createTierTopicProducer(Properties, String) - Static method in class kafka.tier.tools.RecoveryUtils
-
Create and return a new TierTopic Producer object.
- createUUID(FlatBufferBuilder, long, long) - Static method in class kafka.tier.serdes.UUID
-
- CURRENT_VERSION - Static variable in class kafka.tier.TierTopicManagerCommitter
-
- TENANT_PREFIX_REGEX - Static variable in class kafka.common.TenantHelpers
-
- TenantHelpers - Class in kafka.common
-
- TenantHelpers() - Constructor for class kafka.common.TenantHelpers
-
- throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- TIER_PROPERTIES_CONF_FILE_CONFIG - Static variable in class kafka.tier.tools.RecoveryUtils
-
- TIER_PROPERTIES_CONF_FILE_DOC - Static variable in class kafka.tier.tools.RecoveryUtils
-
- TIER_STATE_TOPIC_PARTITION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STATE_TOPIC_PARTITION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_OFFSET_VALIDATION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_OFFSET_VALIDATION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_VALIDATION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STORAGE_VALIDATION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierAbortedTxnReader - Class in kafka.tier.fetcher
-
- TierAbortedTxnReader() - Constructor for class kafka.tier.fetcher.TierAbortedTxnReader
-
- tierEpoch() - Method in class kafka.tier.domain.AbstractTierMetadata
-
tierEpoch for the tier metadata
- tierEpoch() - Method in class kafka.tier.domain.TierObjectMetadata
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionFence
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.InitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- tierEpoch() - Method in class kafka.tier.state.FileTierPartitionState
-
- tierEpoch() - Method in class kafka.tier.state.Header
-
- tierEpoch() - Method in interface kafka.tier.state.TierPartitionState
-
Return the current tierEpoch.
- tierEpoch() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- TierFetcher - Class in kafka.tier.fetcher
-
- TierFetcher(Time, TierFetcherConfig, TierObjectStore, KafkaScheduler, Metrics, LogContext) - Constructor for class kafka.tier.fetcher.TierFetcher
-
- TierFetcherConfig - Class in kafka.tier.fetcher
-
- TierFetcherConfig(KafkaConfig) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig(int, int, int, int, Long) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig() - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- tierFetcherMetrics - Variable in class kafka.tier.fetcher.TierFetcher
-
- TierFetchResult - Class in kafka.tier.fetcher
-
- TierFetchResult(ReclaimableMemoryRecords, List<AbortedTxn>, Throwable) - Constructor for class kafka.tier.fetcher.TierFetchResult
-
- TierKafkaKey - Class in kafka.tier.serdes
-
- TierKafkaKey() - Constructor for class kafka.tier.serdes.TierKafkaKey
-
- tierLogSegmentForOffset(TierPartitionState, long, Optional<TierObjectStore>) - Static method in class kafka.tier.state.TierUtils
-
- TierMessageFormatter - Class in kafka.tier.topic
-
- TierMessageFormatter() - Constructor for class kafka.tier.topic.TierMessageFormatter
-
- TierMetadataComparator - Class in kafka.tier.tools
-
This tool will act as the downstream of the fencing tool in the recovery workflow
Once the fenced tier topic details are available as input, this tool will do the following:
1.
- TierMetadataComparator(Properties, List<FenceEventInfo>, Path) - Constructor for class kafka.tier.tools.TierMetadataComparator
-
- TierMetadataDebugger - Class in kafka.tier.tools
-
TierMetadataDebugger is a tool to dump raw metadata events of TierTopicPartitions, additionally it can also materialize and
generate expected state.
- TierMetadataDebugger() - Constructor for class kafka.tier.tools.TierMetadataDebugger
-
- TierMetadataDeserializationException - Exception in kafka.tier.exceptions
-
TierMetadataDeserializationException
is an exception for cases where metadata
belonging to the tier topic cannot be deserialized.
- TierMetadataDeserializationException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataFatalException - Exception in kafka.tier.exceptions
-
- TierMetadataFatalException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataRetriableException - Exception in kafka.tier.exceptions
-
- TierMetadataRetriableException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataValidator - Class in kafka.tier.tools
-
TierMetadataValidator: Tool to validate the materialization of the tier topic partition's materialization states.
- tierNamespace - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- TierObjectMetadata - Class in kafka.tier.domain
-
- TierObjectMetadata(TopicIdPartition, TierPartitionStateEntry) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TopicIdPartition, int, UUID, long, long, long, int, TierObjectMetadata.State, boolean, boolean, boolean) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TierSegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata.State - Enum in kafka.tier.domain
-
- TierObjectStore - Interface in kafka.tier.store
-
- TierObjectStore.Backend - Enum in kafka.tier.store
-
- TierObjectStore.DataTypePathPrefix - Enum in kafka.tier.store
-
- TierObjectStore.FileType - Enum in kafka.tier.store
-
- TierObjectStore.ObjectMetadata - Class in kafka.tier.store
-
- TierObjectStore.ObjectStoreMetadata - Interface in kafka.tier.store
-
- TierObjectStore.TierStateRestoreSnapshotMetadata - Class in kafka.tier.store
-
- TierObjectStoreConfig - Class in kafka.tier.store
-
- TierObjectStoreConfig(Optional<String>, KafkaConfig) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreConfig(Optional<String>, Optional<Integer>) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreConfig(String, Integer) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreFactory - Class in kafka.tier.tools
-
This class will act as the factory for generating and maintaining the instance map for the various kinds
of the object store backends.
- TierObjectStoreFactory() - Constructor for class kafka.tier.tools.TierObjectStoreFactory
-
- TierObjectStoreFatalException - Exception in kafka.tier.exceptions
-
- TierObjectStoreFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreFatalException(String) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreResponse - Interface in kafka.tier.store
-
- TierObjectStoreRetriableException - Exception in kafka.tier.exceptions
-
- TierObjectStoreRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
-
- TierObjectStoreRetriableException(String) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
-
- TierObjectStoreUtils - Class in kafka.tier.store
-
- TierObjectStoreUtils() - Constructor for class kafka.tier.store.TierObjectStoreUtils
-
- TierPartitionDeleteComplete - Class in kafka.tier.domain
-
Partition delete complete metadata.
- TierPartitionDeleteComplete(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteComplete(TopicIdPartition, PartitionDeleteComplete) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteInitiate - Class in kafka.tier.domain
-
Partition delete initiate metadata.
- TierPartitionDeleteInitiate(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionDeleteInitiate(TopicIdPartition, PartitionDeleteInitiate) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionFence - Class in kafka.tier.domain
-
- TierPartitionFence(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionFence
-
- TierPartitionFence(TopicIdPartition, PartitionFence) - Constructor for class kafka.tier.domain.TierPartitionFence
-
- TierPartitionForceRestore - Class in kafka.tier.domain
-
- TierPartitionForceRestore(TopicIdPartition, UUID, long, long, OffsetAndEpoch, String) - Constructor for class kafka.tier.domain.TierPartitionForceRestore
-
- TierPartitionForceRestore(TopicIdPartition, PartitionForceRestore) - Constructor for class kafka.tier.domain.TierPartitionForceRestore
-
- TierPartitionState - Interface in kafka.tier.state
-
- TierPartitionState.AppendResult - Enum in kafka.tier.state
-
The result of an attempt to append a tier metadata entry.
- TierPartitionState.RestoreResult - Enum in kafka.tier.state
-
The result of an attempt to restore a TierPartitionState via a PartitionForceRestore event
- TierPartitionStateEntry - Class in kafka.tier.serdes
-
- TierPartitionStateEntry() - Constructor for class kafka.tier.serdes.TierPartitionStateEntry
-
- TierPartitionStateFactory - Class in kafka.tier.state
-
- TierPartitionStateFactory(boolean) - Constructor for class kafka.tier.state.TierPartitionStateFactory
-
- TierPartitionStateFencingTrigger - Class in kafka.tier.tools
-
A tool that injects PartitionFence events into TierTopic for a provided list of
TopicIdPartition.
- TierPartitionStateFencingTrigger() - Constructor for class kafka.tier.tools.TierPartitionStateFencingTrigger
-
- TierPartitionStateHeader - Class in kafka.tier.serdes
-
- TierPartitionStateHeader() - Constructor for class kafka.tier.serdes.TierPartitionStateHeader
-
- TierPartitionStateIllegalListenerException - Exception in kafka.tier.exceptions
-
- TierPartitionStateIllegalListenerException(String) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateRestoreTrigger - Class in kafka.tier.tools
-
A tool that injects PartitionForceRestore events into TierTopic for a provided list of
TopicIdPartition.
- TierPartitionStateRestoreTrigger() - Constructor for class kafka.tier.tools.TierPartitionStateRestoreTrigger
-
- TierPartitionStatus - Enum in kafka.tier.state
-
- TierRecordType - Enum in kafka.tier.domain
-
- TierRecoveryConfig - Class in kafka.tier.tools
-
- TierRecoveryConfig() - Constructor for class kafka.tier.tools.TierRecoveryConfig
-
- TierReplicaManager - Class in kafka.tier
-
Replica manager for tiered storage.
- TierReplicaManager() - Constructor for class kafka.tier.TierReplicaManager
-
- TierReplicaManager.ChangeListener - Interface in kafka.tier
-
Interface to register callbacks on the lifecycle of tiering enabled topic partitions.
- TierSegmentDeleteComplete - Class in kafka.tier.domain
-
Delete complete metadata.
- TierSegmentDeleteComplete(TopicIdPartition, int, UUID, Optional<OffsetAndEpoch>) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteComplete(TopicIdPartition, SegmentDeleteComplete) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteComplete(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteInitiate - Class in kafka.tier.domain
-
Segment delete initiate metadata.
- TierSegmentDeleteInitiate(TopicIdPartition, int, UUID, Optional<OffsetAndEpoch>) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentDeleteInitiate(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentDeleteInitiate(TopicIdPartition, SegmentDeleteInitiate) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentReader - Class in kafka.tier.fetcher
-
- TierSegmentReader(String) - Constructor for class kafka.tier.fetcher.TierSegmentReader
-
- TierSegmentReader.NextOffsetAndBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentReader.RecordsAndNextBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentUploadComplete - Class in kafka.tier.domain
-
Upload complete metadata.
- TierSegmentUploadComplete(TopicIdPartition, int, UUID, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TierSegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TopicIdPartition, SegmentUploadComplete) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadInitiate - Class in kafka.tier.domain
-
Upload initiate metadata.
- TierSegmentUploadInitiate(TopicIdPartition, int, UUID, long, long, long, int, boolean, boolean, boolean, OffsetAndEpoch) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierSegmentUploadInitiate(TopicIdPartition, SegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierStateFetcher - Class in kafka.tier.fetcher
-
- TierStateFetcher(Integer, TierObjectStore) - Constructor for class kafka.tier.fetcher.TierStateFetcher
-
- tierStateFile() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- TierStateRestoreSnapshotMetadata(TopicIdPartition, long, long, String) - Constructor for class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- TierStateRestoreSnapshotMetadata(TierPartitionForceRestore) - Constructor for class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- TierTimestampAndOffset - Class in kafka.tier
-
- TierTimestampAndOffset(long, TierObjectStore.ObjectMetadata, int) - Constructor for class kafka.tier.TierTimestampAndOffset
-
- tierTimestampAndOffsets() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
TierTimestampAndOffsets that will be resolved by this fetch
- TierTopic - Class in kafka.tier.topic
-
- TierTopic(String) - Constructor for class kafka.tier.topic.TierTopic
-
- TierTopicAppender - Interface in kafka.tier.topic
-
TierTopicAppender allows interaction with a TierTopic.
- TierTopicClient - Class in kafka.tier.client
-
- TierTopicClient() - Constructor for class kafka.tier.client.TierTopicClient
-
- TierTopicConsumer - Class in kafka.tier.topic
-
Tier topic consumer.
- TierTopicConsumer(TierTopicManagerConfig, LogDirFailureChannel, TierStateFetcher, Metrics, Time) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer(TierTopicManagerConfig, Supplier<Consumer<byte[], byte[]>>, Supplier<Consumer<byte[], byte[]>>, TierTopicManagerCommitter, TierStateFetcher, Optional<Metrics>, Time) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer.ClientCtx - Interface in kafka.tier.topic
-
- TierTopicConsumerSupplier - Class in kafka.tier.client
-
- TierTopicConsumerSupplier(TierTopicManagerConfig, String) - Constructor for class kafka.tier.client.TierTopicConsumerSupplier
-
- TierTopicIncorrectPartitionCountException - Exception in kafka.tier.exceptions
-
- TierTopicIncorrectPartitionCountException(String) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicInitLeader - Class in kafka.tier.domain
-
Init leader metadata.
- TierTopicInitLeader(TopicIdPartition, int, UUID, int) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicInitLeader(TopicIdPartition, InitLeader) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicManager - Class in kafka.tier.topic
-
A metadata store for tiered storage.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<Producer<byte[], byte[]>>, Supplier<AdminZkClient>) - Constructor for class kafka.tier.topic.TierTopicManager
-
Instantiate TierTopicManager.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<AdminZkClient>) - Constructor for class kafka.tier.topic.TierTopicManager
-
Primary public constructor for TierTopicManager.
- TierTopicManagerCommitter - Class in kafka.tier
-
- TierTopicManagerCommitter(TierTopicManagerConfig, LogDirFailureChannel) - Constructor for class kafka.tier.TierTopicManagerCommitter
-
Instantiate a TierTopicManagerCommitter
- TierTopicManagerConfig - Class in kafka.tier.topic
-
- TierTopicManagerConfig(Supplier<Map<String, Object>>, String, short, short, int, String, Long, Integer, Integer, List<String>) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicManagerConfig(KafkaConfig, Supplier<Map<String, Object>>, String) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicMaterializationToolConfig - Class in kafka.tier.tools
-
- TierTopicMaterializationToolConfig(Properties) - Constructor for class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierTopicMaterializationUtils - Class in kafka.tier.tools
-
TierTopicMaterializationUtils provides utils for dumping materialization events from tier topic for the given source
topic(or all) for a give source partition(or all).
- TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, Properties, Map<TopicIdPartition, Long>) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
-
- TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, Properties) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
-
- TierTopicPartitioner - Class in kafka.tier.topic
-
- TierTopicPartitioner(int) - Constructor for class kafka.tier.topic.TierTopicPartitioner
-
- TierTopicProducerSupplier - Class in kafka.tier.client
-
- TierTopicProducerSupplier(TierTopicManagerConfig) - Constructor for class kafka.tier.client.TierTopicProducerSupplier
-
- TierUtils - Class in kafka.tier.state
-
- TierUtils() - Constructor for class kafka.tier.state.TierUtils
-
- timestamp - Variable in class kafka.tier.TierTimestampAndOffset
-
- timestamp() - Method in class kafka.tier.TierTimestampAndOffset
-
- toArray(InputStream) - Static method in class kafka.tier.fetcher.TierStateFetcher
-
Read the input stream from its current position to its limit into a byte array.
- toByte(TierRecordType) - Static method in enum kafka.tier.domain.TierRecordType
-
- toByte(TierPartitionStatus) - Static method in enum kafka.tier.state.TierPartitionStatus
-
- toJson() - Method in class kafka.common.TopicPlacement
-
Serialize this object back to json string.
- toJson() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- toJson() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- toJson() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- toPath(String, TierObjectStore.FileType) - Method in interface kafka.tier.store.TierObjectStore.ObjectStoreMetadata
-
Converts the ObjectStoreMetadata to an object store key path, taking into account a
given key prefix and file type
- toPath(String, TierObjectStore.FileType) - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- topic - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- topic() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- topic() - Method in class kafka.tier.TopicIdPartition
-
- topicId() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId() - Method in class kafka.tier.state.Header
-
- topicId() - Method in class kafka.tier.TopicIdPartition
-
- topicIdAsBase64() - Method in class kafka.tier.TopicIdPartition
-
- topicIdBase64 - Variable in class kafka.tier.tools.common.FenceEventInfo
-
- topicIdBase64() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- topicIdPartition() - Method in class kafka.tier.domain.AbstractTierMetadata
-
Topic-partition corresponding to this tier metadata.
- topicIdPartition() - Method in class kafka.tier.domain.TierObjectMetadata
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionFence
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- topicIdPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicIdPartition() - Method in interface kafka.tier.state.TierPartitionState
-
Optional TopicIdPartition corresponding to this TierPartition
If one has not been set, returns empty
- topicIdPartition() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- topicIdPartition() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- topicIdPartition() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- TopicIdPartition - Class in kafka.tier
-
- TopicIdPartition(String, UUID, int) - Constructor for class kafka.tier.TopicIdPartition
-
- topicName() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicName() - Method in interface kafka.tier.topic.InitializedTierTopic
-
- topicName() - Method in class kafka.tier.topic.TierTopic
-
- topicName(String) - Static method in class kafka.tier.topic.TierTopic
-
- topicNameAsByteBuffer() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicNameInByteBuffer(ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicPartition() - Method in interface kafka.tier.state.TierPartitionState
-
The topic-partition corresponding to this TierPartition.
- topicPartition() - Method in class kafka.tier.TopicIdPartition
-
- TopicPlacement - Class in kafka.common
-
- TopicPlacement.ConstraintCount - Class in kafka.common
-
- TopicPlacement.Replica - Class in kafka.common
-
- TopicPlacement.TopicPlacementValidator - Class in kafka.common
-
- toSend(String) - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- toState(byte) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
- toString() - Method in class kafka.common.BrokerRemovalDescriptionInternal
-
- toString() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- toString() - Method in class kafka.common.TopicPlacement.Replica
-
- toString() - Method in class kafka.common.TopicPlacement
-
- toString() - Method in class kafka.tier.domain.TierObjectMetadata
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierPartitionFence
-
- toString() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- toString() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- toString() - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchKey
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- toString() - Method in class kafka.tier.fetcher.TierSegmentReader.NextOffsetAndBatchMetadata
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState
-
- toString() - Method in class kafka.tier.state.Header
-
- toString() - Method in class kafka.tier.state.OffsetAndEpoch
-
- toString() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- toString() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-
- toString() - Method in class kafka.tier.TierTimestampAndOffset
-
- toString() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorOutput
-
- toString() - Method in class kafka.tier.tools.common.ComparatorInfo.ComparatorReplicaInfo
-
- toString() - Method in class kafka.tier.tools.common.FenceEventInfo
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorInput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreComparatorOutput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawInput
-
- toString() - Method in class kafka.tier.tools.common.RestoreInfo.RestoreRawOutput
-
- toString() - Method in class kafka.tier.TopicIdPartition
-
- totalSize() - Method in class kafka.tier.state.FileTierPartitionState
-
- totalSize() - Method in interface kafka.tier.state.TierPartitionState
-
Sum the size of all segment spanned by this TierPartitionState.
- toTierTopicPartition(TopicIdPartition) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartition(TopicIdPartition) - Method in class kafka.tier.topic.TierTopic
-
- toTierTopicPartition(TopicIdPartition, String, TierTopicPartitioner) - Static method in class kafka.tier.topic.TierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in class kafka.tier.topic.TierTopic
-
Generate the tier topic partitions containing data for tiered partitions.
- toTierTopicPartitions(Collection<TopicIdPartition>, String, TierTopicPartitioner) - Static method in class kafka.tier.topic.TierTopic
-
- toTopicIdPartitions(List<String>) - Static method in class kafka.tier.tools.RecoveryUtils
-
Converts a list of formatted TopicIdPartition strings to a list of TopicIdPartition.
- toType(byte) - Static method in enum kafka.tier.domain.TierRecordType
-
- trackMaterialization(AbstractTierMetadata, CompletableFuture<TierPartitionState.AppendResult>) - Method in class kafka.tier.topic.TierTopicConsumer
-
Track materialization of provided metadata.
- tryBecomeReady(boolean) - Method in class kafka.tier.topic.TierTopicManager
-
Try to move the TierTopicManager to ready state.
- tryExtendLease(long) - Method in class kafka.tier.fetcher.MemoryTracker.MemoryLease
-
Attempts to extend the lease by amount additional bytes.
- tryLease(long) - Method in class kafka.tier.fetcher.MemoryTracker
-
Like newLease, this will attempt to create a new MemoryLease for the provided amount of
bytes.
- type() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierPartitionFence
-
- type() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- type() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- VALIDATE - Static variable in class kafka.tier.tools.TierRecoveryConfig
-
- validateAssignment(TopicPlacement, List<TopicPlacement.Replica>, List<TopicPlacement.Replica>) - Static method in class kafka.common.TopicPlacement
-
Returns an error string if the sync and observer replica assignment doesn't match the constraints.
- validatePartitions(Properties, Set<TopicPartition>) - Static method in class kafka.tier.tools.RecoveryUtils
-
- validateReconfiguration(Map<String, ?>) - Method in class kafka.metrics.KafkaYammerMetrics
-
- validateReconfiguration(KafkaConfig) - Method in class kafka.tier.fetcher.TierFetcher
-
- validateStates(Path, Path, TopicPartition, long) - Method in class kafka.tier.tools.TierMetadataValidator
-
For the given 'expected' and 'actual' metadata states path, the method will validate if they
are same or not.
- validationSuccess() - Method in class kafka.tier.tools.common.RestoreInfo.ComparatorReplicaInfo
-
- VALIDATOR - Static variable in class kafka.common.TopicPlacement
-
- validBytes() - Method in class kafka.tier.fetcher.ReclaimableMemoryRecords
-
- valueOf(String) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.domain.TierRecordType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.RestoreResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.Backend
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.domain.TierRecordType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.RestoreResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.Backend
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.DataTypePathPrefix
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- version() - Method in class kafka.common.TopicPlacement
-
- version() - Method in class kafka.tier.domain.TierObjectMetadata
-
- version() - Method in class kafka.tier.domain.TierPartitionForceRestore
-
- version() - Method in class kafka.tier.serdes.InitLeader
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteComplete
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.PartitionFence
-
- version() - Method in class kafka.tier.serdes.PartitionForceRestore
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- version() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- version() - Method in class kafka.tier.store.TierObjectStore.TierStateRestoreSnapshotMetadata
-