Package org.apache.kafka.server.log.remote.storage
package org.apache.kafka.server.log.remote.storage
Provides a pluggable API for defining remote storage and retrieval of Kafka log segments.
-
ClassDescriptionThis represents all the required data and indexes for a specific log segment that needs to be stored in the remote storage.Base class for remote log metadata objects like
RemoteLogSegmentMetadata
,RemoteLogSegmentMetadataUpdate
, andRemotePartitionDeleteMetadata
.This interface provides storing and fetching remote log segment metadata with strongly consistent semantics.This class represents a universally unique identifier associated to a topic partition's log segment.It describes the metadata about a topic partition's remote log segment in the remote storage.Custom metadata from aRemoteStorageManager
plugin.It describes the metadata update about the log segment in the remote storage.This enum indicates the state of the remote log segment.This class represents the metadata about the remote partition.This enum indicates the deletion state of the remote topic partition.Exception thrown when a resource is not found on the remote storage.Exception thrown when there is a remote storage error.This interface provides the lifecycle of remote log segments that includes copy, fetch, and delete from remote storage.Type of the index file.This class contains the metrics related to tiered storage feature, which is to have a centralized place to store them, so that we can verify all of them easily.