- throwExceptionOnSegmentFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- throwExceptionOnTransactionFetch - Variable in class kafka.tier.store.MockInMemoryTierObjectStore
-
- TIER_STATE_TOPIC_PARTITION - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TIER_STATE_TOPIC_PARTITION_DOC - Static variable in class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierAbortedTxnReader - Class in kafka.tier.fetcher
-
- TierAbortedTxnReader() - Constructor for class kafka.tier.fetcher.TierAbortedTxnReader
-
- tieredSegments(NavigableSet<Long>, TierPartitionState, Optional<TierObjectStore>) - Static method in class kafka.tier.state.TierUtils
-
- tierEpoch() - Method in class kafka.tier.domain.AbstractTierMetadata
-
tierEpoch for the tier metadata
- tierEpoch() - Method in class kafka.tier.domain.TierObjectMetadata
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.InitLeader
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- tierEpoch() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- tierEpoch() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- tierEpoch() - Method in class kafka.tier.state.FileTierPartitionState
-
- tierEpoch() - Method in interface kafka.tier.state.TierPartitionState
-
Return the current tierEpoch.
- tierEpoch() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- TierFetcher - Class in kafka.tier.fetcher
-
- TierFetcher(TierFetcherConfig, TierObjectStore, KafkaScheduler, Metrics, LogContext) - Constructor for class kafka.tier.fetcher.TierFetcher
-
- TierFetcherConfig - Class in kafka.tier.fetcher
-
- TierFetcherConfig(KafkaConfig) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig(int, int, int, int) - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- TierFetcherConfig() - Constructor for class kafka.tier.fetcher.TierFetcherConfig
-
- tierFetcherMetrics - Variable in class kafka.tier.fetcher.TierFetcher
-
- TierFetchResult - Class in kafka.tier.fetcher
-
- TierFetchResult(Records, List<AbortedTxn>, Throwable) - Constructor for class kafka.tier.fetcher.TierFetchResult
-
- TierKafkaKey - Class in kafka.tier.serdes
-
- TierKafkaKey() - Constructor for class kafka.tier.serdes.TierKafkaKey
-
- tierLogSegmentForOffset(TierPartitionState, long, Optional<TierObjectStore>) - Static method in class kafka.tier.state.TierUtils
-
- TierMessageFormatter - Class in kafka.tier.topic
-
- TierMessageFormatter() - Constructor for class kafka.tier.topic.TierMessageFormatter
-
- TierMetadataDebugger - Class in kafka.tier.tools
-
TierMetadataDebugger is a tool to dump raw metadata events of TierTopicPartitions, additionally it can also materialize and
generate expected state.
- TierMetadataDebugger() - Constructor for class kafka.tier.tools.TierMetadataDebugger
-
- TierMetadataDeserializationException - Exception in kafka.tier.exceptions
-
TierMetadataDeserializationException
is an exception for cases where metadata
belonging to the tier topic cannot be deserialized.
- TierMetadataDeserializationException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataDeserializationException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataDeserializationException
-
- TierMetadataFatalException - Exception in kafka.tier.exceptions
-
- TierMetadataFatalException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataFatalException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataFatalException
-
- TierMetadataRetriableException - Exception in kafka.tier.exceptions
-
- TierMetadataRetriableException(String) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataRetriableException(Throwable) - Constructor for exception kafka.tier.exceptions.TierMetadataRetriableException
-
- TierMetadataValidator - Class in kafka.tier.tools
-
TierMetadataValidator: Tool to validate the materialization of the tier topic partition's materialization states.
- tierNamespace - Variable in class kafka.tier.topic.TierTopicManagerConfig
-
- TierObjectMetadata - Class in kafka.tier.domain
-
- TierObjectMetadata(TopicIdPartition, TierPartitionStateEntry) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TopicIdPartition, int, UUID, long, long, long, int, TierObjectMetadata.State, boolean, boolean, boolean) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata(TierSegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierObjectMetadata
-
- TierObjectMetadata.State - Enum in kafka.tier.domain
-
- TierObjectStore - Interface in kafka.tier.store
-
- TierObjectStore.FileType - Enum in kafka.tier.store
-
- TierObjectStore.ObjectMetadata - Class in kafka.tier.store
-
- TierObjectStoreConfig - Class in kafka.tier.store
-
- TierObjectStoreConfig(String, KafkaConfig) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreConfig(String, Integer) - Constructor for class kafka.tier.store.TierObjectStoreConfig
-
- TierObjectStoreFatalException - Exception in kafka.tier.exceptions
-
- TierObjectStoreFatalException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreFatalException(String) - Constructor for exception kafka.tier.exceptions.TierObjectStoreFatalException
-
- TierObjectStoreResponse - Interface in kafka.tier.store
-
- TierObjectStoreRetriableException - Exception in kafka.tier.exceptions
-
- TierObjectStoreRetriableException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierObjectStoreRetriableException
-
- TierObjectStoreUtils - Class in kafka.tier.store
-
- TierObjectStoreUtils() - Constructor for class kafka.tier.store.TierObjectStoreUtils
-
- TierPartitionDeleteComplete - Class in kafka.tier.domain
-
- TierPartitionDeleteComplete(TopicIdPartition, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteComplete(TopicIdPartition, PartitionDeleteComplete) - Constructor for class kafka.tier.domain.TierPartitionDeleteComplete
-
- TierPartitionDeleteInitiate - Class in kafka.tier.domain
-
- TierPartitionDeleteInitiate(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionDeleteInitiate(TopicIdPartition, PartitionDeleteInitiate) - Constructor for class kafka.tier.domain.TierPartitionDeleteInitiate
-
- TierPartitionState - Interface in kafka.tier.state
-
- TierPartitionState.AppendResult - Enum in kafka.tier.state
-
The result of an attempt to append a tier metadata entry.
- TierPartitionStateEntry - Class in kafka.tier.serdes
-
- TierPartitionStateEntry() - Constructor for class kafka.tier.serdes.TierPartitionStateEntry
-
- TierPartitionStateFactory - Class in kafka.tier.state
-
- TierPartitionStateFactory(boolean) - Constructor for class kafka.tier.state.TierPartitionStateFactory
-
- TierPartitionStateHeader - Class in kafka.tier.serdes
-
- TierPartitionStateHeader() - Constructor for class kafka.tier.serdes.TierPartitionStateHeader
-
- TierPartitionStateIllegalListenerException - Exception in kafka.tier.exceptions
-
- TierPartitionStateIllegalListenerException(String) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStateIllegalListenerException(Throwable) - Constructor for exception kafka.tier.exceptions.TierPartitionStateIllegalListenerException
-
- TierPartitionStatus - Enum in kafka.tier.state
-
- TierRecordType - Enum in kafka.tier.domain
-
- TierReplicaManager - Class in kafka.tier
-
Replica manager for tiered storage.
- TierReplicaManager() - Constructor for class kafka.tier.TierReplicaManager
-
- TierReplicaManager.ChangeListener - Interface in kafka.tier
-
Interface to register callbacks on the lifecycle of tiering enabled topic partitions.
- TierSegmentDeleteComplete - Class in kafka.tier.domain
-
- TierSegmentDeleteComplete(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteComplete(TopicIdPartition, SegmentDeleteComplete) - Constructor for class kafka.tier.domain.TierSegmentDeleteComplete
-
- TierSegmentDeleteInitiate - Class in kafka.tier.domain
-
- TierSegmentDeleteInitiate(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentDeleteInitiate(TopicIdPartition, SegmentDeleteInitiate) - Constructor for class kafka.tier.domain.TierSegmentDeleteInitiate
-
- TierSegmentReader - Class in kafka.tier.fetcher
-
- TierSegmentReader(String) - Constructor for class kafka.tier.fetcher.TierSegmentReader
-
- TierSegmentReader.NextOffsetAndBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentReader.RecordsAndNextBatchMetadata - Class in kafka.tier.fetcher
-
- TierSegmentUploadComplete - Class in kafka.tier.domain
-
- TierSegmentUploadComplete(TopicIdPartition, int, UUID) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TierSegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadComplete(TopicIdPartition, SegmentUploadComplete) - Constructor for class kafka.tier.domain.TierSegmentUploadComplete
-
- TierSegmentUploadInitiate - Class in kafka.tier.domain
-
- TierSegmentUploadInitiate(TopicIdPartition, int, UUID, long, long, long, int, boolean, boolean, boolean) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierSegmentUploadInitiate(TopicIdPartition, SegmentUploadInitiate) - Constructor for class kafka.tier.domain.TierSegmentUploadInitiate
-
- TierStateFetcher - Class in kafka.tier.fetcher
-
- TierStateFetcher(Integer, TierObjectStore) - Constructor for class kafka.tier.fetcher.TierStateFetcher
-
- TierTimestampAndOffset - Class in kafka.tier
-
- TierTimestampAndOffset(long, TierObjectStore.ObjectMetadata, int) - Constructor for class kafka.tier.TierTimestampAndOffset
-
- tierTimestampAndOffsets() - Method in class kafka.tier.fetcher.PendingOffsetForTimestamp
-
TierTimestampAndOffsets that will be resolved by this fetch
- TierTopic - Class in kafka.tier.topic
-
- TierTopic(String, Supplier<AdminZkClient>) - Constructor for class kafka.tier.topic.TierTopic
-
- TierTopicAppender - Interface in kafka.tier.topic
-
TierTopicAppender allows interaction with a TierTopic.
- TierTopicClient - Class in kafka.tier.client
-
- TierTopicClient() - Constructor for class kafka.tier.client.TierTopicClient
-
- TierTopicConsumer - Class in kafka.tier.topic
-
Tier topic consumer.
- TierTopicConsumer(TierTopicManagerConfig, LogDirFailureChannel) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer(TierTopicManagerConfig, Supplier<Consumer<byte[], byte[]>>, Supplier<Consumer<byte[], byte[]>>, TierTopicManagerCommitter) - Constructor for class kafka.tier.topic.TierTopicConsumer
-
- TierTopicConsumer.ClientCtx - Interface in kafka.tier.topic
-
- TierTopicConsumerSupplier - Class in kafka.tier.client
-
- TierTopicConsumerSupplier(TierTopicManagerConfig, String) - Constructor for class kafka.tier.client.TierTopicConsumerSupplier
-
- TierTopicIncorrectPartitionCountException - Exception in kafka.tier.exceptions
-
- TierTopicIncorrectPartitionCountException(String) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(String, Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicIncorrectPartitionCountException(Throwable) - Constructor for exception kafka.tier.exceptions.TierTopicIncorrectPartitionCountException
-
- TierTopicInitLeader - Class in kafka.tier.domain
-
- TierTopicInitLeader(TopicIdPartition, int, UUID, int) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicInitLeader(TopicIdPartition, InitLeader) - Constructor for class kafka.tier.domain.TierTopicInitLeader
-
- TierTopicManager - Class in kafka.tier.topic
-
A metadata store for tiered storage.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<Producer<byte[], byte[]>>, Supplier<AdminZkClient>) - Constructor for class kafka.tier.topic.TierTopicManager
-
Instantiate TierTopicManager.
- TierTopicManager(TierTopicManagerConfig, TierTopicConsumer, Supplier<AdminZkClient>, Metrics) - Constructor for class kafka.tier.topic.TierTopicManager
-
Primary public constructor for TierTopicManager.
- TierTopicManagerCommitter - Class in kafka.tier
-
- TierTopicManagerCommitter(TierTopicManagerConfig, LogDirFailureChannel) - Constructor for class kafka.tier.TierTopicManagerCommitter
-
Instantiate a TierTopicManagerCommitter
- TierTopicManagerConfig - Class in kafka.tier.topic
-
- TierTopicManagerConfig(Supplier<Map<String, Object>>, String, short, short, int, String, Long, Integer, Integer, List<String>) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicManagerConfig(KafkaConfig, Supplier<Map<String, Object>>, String) - Constructor for class kafka.tier.topic.TierTopicManagerConfig
-
- TierTopicMaterializationToolConfig - Class in kafka.tier.tools
-
- TierTopicMaterializationToolConfig(Properties) - Constructor for class kafka.tier.tools.TierTopicMaterializationToolConfig
-
- TierTopicMaterializationUtils - Class in kafka.tier.tools
-
TierTopicMaterializationUtils provides utils for dumping materialization events from tier topic for the given source
topic(or all) for a give source partition(or all).
- TierTopicMaterializationUtils(TierTopicMaterializationToolConfig, HashMap<TopicIdPartition, Long>) - Constructor for class kafka.tier.tools.TierTopicMaterializationUtils
-
- TierTopicPartitioner - Class in kafka.tier.topic
-
- TierTopicPartitioner(int) - Constructor for class kafka.tier.topic.TierTopicPartitioner
-
- TierTopicProducerSupplier - Class in kafka.tier.client
-
- TierTopicProducerSupplier(TierTopicManagerConfig) - Constructor for class kafka.tier.client.TierTopicProducerSupplier
-
- TierUtils - Class in kafka.tier.state
-
- TierUtils() - Constructor for class kafka.tier.state.TierUtils
-
- timestamp - Variable in class kafka.tier.TierTimestampAndOffset
-
- timestamp() - Method in class kafka.tier.TierTimestampAndOffset
-
- toByte(TierRecordType) - Static method in enum kafka.tier.domain.TierRecordType
-
- toByte(TierPartitionStatus) - Static method in enum kafka.tier.state.TierPartitionStatus
-
- toJson() - Method in class kafka.common.TopicPlacement
-
Serialize this object back to json string.
- topic() - Method in class kafka.tier.TopicIdPartition
-
- topicId() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicId() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId(UUID) - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- topicId() - Method in class kafka.tier.state.Header
-
- topicId() - Method in class kafka.tier.TopicIdPartition
-
- topicIdAsBase64() - Method in class kafka.tier.TopicIdPartition
-
- topicIdPartition() - Method in class kafka.tier.domain.AbstractTierMetadata
-
Topic-partition corresponding to this tier metadata.
- topicIdPartition() - Method in class kafka.tier.domain.TierObjectMetadata
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- topicIdPartition() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- topicIdPartition() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- topicIdPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicIdPartition() - Method in interface kafka.tier.state.TierPartitionState
-
Optional TopicIdPartition corresponding to this TierPartition
If one has not been set, returns empty
- topicIdPartition() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- TopicIdPartition - Class in kafka.tier
-
- TopicIdPartition(String, UUID, int) - Constructor for class kafka.tier.TopicIdPartition
-
- topicName() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicName() - Method in interface kafka.tier.topic.InitializedTierTopic
-
- topicName() - Method in class kafka.tier.topic.TierTopic
-
- topicName(String) - Static method in class kafka.tier.topic.TierTopic
-
- topicNameAsByteBuffer() - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicNameInByteBuffer(ByteBuffer) - Method in class kafka.tier.serdes.TierKafkaKey
-
- topicPartition() - Method in class kafka.tier.state.FileTierPartitionState
-
- topicPartition() - Method in interface kafka.tier.state.TierPartitionState
-
The topic-partition corresponding to this TierPartition.
- topicPartition() - Method in class kafka.tier.TopicIdPartition
-
- TopicPlacement - Class in kafka.common
-
- TopicPlacement.ConstraintCount - Class in kafka.common
-
- TopicPlacement.Replica - Class in kafka.common
-
- TopicPlacement.TopicPlacementValidator - Class in kafka.common
-
- toState(byte) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
- toString() - Method in class kafka.common.TopicPlacement.ConstraintCount
-
- toString() - Method in class kafka.common.TopicPlacement.Replica
-
- toString() - Method in class kafka.common.TopicPlacement
-
- toString() - Method in class kafka.tier.domain.TierObjectMetadata
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- toString() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- toString() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.CachedFetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchKey
-
- toString() - Method in class kafka.tier.fetcher.offsetcache.FetchOffsetMetadata
-
- toString() - Method in class kafka.tier.fetcher.TierSegmentReader.NextOffsetAndBatchMetadata
-
- toString() - Method in class kafka.tier.state.FileTierPartitionState
-
- toString() - Method in class kafka.tier.state.Header
-
- toString() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-
- toString() - Method in class kafka.tier.TierTimestampAndOffset
-
- toString() - Method in class kafka.tier.TopicIdPartition
-
- totalSize() - Method in class kafka.tier.state.FileTierPartitionState
-
- totalSize() - Method in interface kafka.tier.state.TierPartitionState
-
Sum the size of all segment spanned by this TierPartitionState.
- toTierTopicPartition(TopicIdPartition) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartition(TopicIdPartition) - Method in class kafka.tier.topic.TierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in interface kafka.tier.topic.InitializedTierTopic
-
- toTierTopicPartitions(Collection<TopicIdPartition>) - Method in class kafka.tier.topic.TierTopic
-
Generate the tier topic partitions containing data for tiered partitions.
- toType(byte) - Static method in enum kafka.tier.domain.TierRecordType
-
- trackMaterialization(AbstractTierMetadata, CompletableFuture<TierPartitionState.AppendResult>) - Method in class kafka.tier.topic.TierTopicConsumer
-
Track materialization of provided metadata.
- tryBecomeReady(boolean) - Method in class kafka.tier.topic.TierTopicManager
-
Try to move the TierTopicManager to ready state.
- type() - Method in class kafka.tier.domain.AbstractTierMetadata
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierPartitionDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentDeleteInitiate
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadComplete
-
- type() - Method in class kafka.tier.domain.TierSegmentUploadInitiate
-
- type() - Method in class kafka.tier.domain.TierTopicInitLeader
-
- validateAssignment(TopicPlacement, List<TopicPlacement.Replica>, List<TopicPlacement.Replica>) - Static method in class kafka.common.TopicPlacement
-
Returns an error string if the sync and observer replica assignment doesn't match the constraints.
- VALIDATOR - Static variable in class kafka.common.TopicPlacement
-
- valueOf(String) - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.domain.TierRecordType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum kafka.tier.domain.TierObjectMetadata.State
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.domain.TierRecordType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionState.AppendResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.state.TierPartitionStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum kafka.tier.store.TierObjectStore.FileType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- version() - Method in class kafka.common.TopicPlacement
-
- version() - Method in class kafka.tier.domain.TierObjectMetadata
-
- version() - Method in class kafka.tier.serdes.InitLeader
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteComplete
-
- version() - Method in class kafka.tier.serdes.PartitionDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteComplete
-
- version() - Method in class kafka.tier.serdes.SegmentDeleteInitiate
-
- version() - Method in class kafka.tier.serdes.SegmentUploadComplete
-
- version() - Method in class kafka.tier.serdes.SegmentUploadInitiate
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateEntry
-
- version() - Method in class kafka.tier.serdes.TierPartitionStateHeader
-
- version() - Method in class kafka.tier.store.TierObjectStore.ObjectMetadata
-