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