Package org.apache.kafka.server.log.remote.storage
-
Interface Summary Interface Description RemoteLogMetadataManager This interface provides storing and fetching remote log segment metadata with strongly consistent semantics.RemoteStorageManager This interface provides the lifecycle of remote log segments that includes copy, fetch, and delete from remote storage. -
Class Summary Class Description LogSegmentData This represents all the required data and indexes for a specific log segment that needs to be stored in the remote storage.RemoteLogMetadata Base class for remote log metadata objects likeRemoteLogSegmentMetadata
,RemoteLogSegmentMetadataUpdate
, andRemotePartitionDeleteMetadata
.RemoteLogSegmentId This class represents a universally unique identifier associated to a topic partition's log segment.RemoteLogSegmentMetadata It describes the metadata about a topic partition's remote log segment in the remote storage.RemoteLogSegmentMetadataUpdate It describes the metadata update about the log segment in the remote storage.RemotePartitionDeleteMetadata This class represents the metadata about the remote partition. -
Enum Summary Enum Description RemoteLogSegmentState This enum indicates the state of the remote log segment.RemotePartitionDeleteState This enum indicates the deletion state of the remote topic partition.RemoteStorageManager.IndexType Type of the index file. -
Exception Summary Exception Description RemoteResourceNotFoundException Exception thrown when a resource is not found on the remote storage.RemoteStorageException Exception thrown when there is a remote storage error.