- REMOTE_COPY_BYTES_PER_SEC_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_COPY_REQUESTS_PER_SEC_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_FETCH_BYTES_PER_SEC_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_FETCH_REQUESTS_PER_SEC_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_LOG_MANAGER_TASKS_AVG_IDLE_PERCENT_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_LOG_READER_AVG_IDLE_PERCENT_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_LOG_READER_TASK_QUEUE_SIZE_METRIC - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- REMOTE_STORAGE_THREAD_POOL_METRICS - Static variable in class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-
- RemoteLogMetadata - Class in org.apache.kafka.server.log.remote.storage
-
- RemoteLogMetadataManager - Interface in org.apache.kafka.server.log.remote.storage
-
This interface provides storing and fetching remote log segment metadata with strongly consistent semantics.
- RemoteLogSegmentId - Class in org.apache.kafka.server.log.remote.storage
-
This class represents a universally unique identifier associated to a topic partition's log segment.
- RemoteLogSegmentId(TopicIdPartition, Uuid) - Constructor for class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentId
-
- remoteLogSegmentId() - Method in class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata
-
- remoteLogSegmentId() - Method in class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate
-
- remoteLogSegmentMetadata(TopicIdPartition, int, long) - Method in interface org.apache.kafka.server.log.remote.storage.RemoteLogMetadataManager
-
- RemoteLogSegmentMetadata - Class in org.apache.kafka.server.log.remote.storage
-
It describes the metadata about a topic partition's remote log segment in the remote storage.
- RemoteLogSegmentMetadata(RemoteLogSegmentId, long, long, long, int, long, int, Optional<RemoteLogSegmentMetadata.CustomMetadata>, RemoteLogSegmentState, Map<Integer, Long>) - Constructor for class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata
-
Creates an instance with the given metadata of remote log segment.
- RemoteLogSegmentMetadata(RemoteLogSegmentId, long, long, long, int, long, int, Map<Integer, Long>) - Constructor for class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadata
-
- RemoteLogSegmentMetadata.CustomMetadata - Class in org.apache.kafka.server.log.remote.storage
-
- RemoteLogSegmentMetadataUpdate - Class in org.apache.kafka.server.log.remote.storage
-
It describes the metadata update about the log segment in the remote storage.
- RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId, long, Optional<RemoteLogSegmentMetadata.CustomMetadata>, RemoteLogSegmentState, int) - Constructor for class org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate
-
- RemoteLogSegmentState - Enum in org.apache.kafka.server.log.remote.storage
-
This enum indicates the state of the remote log segment.
- remoteLogSize(TopicIdPartition, int) - Method in interface org.apache.kafka.server.log.remote.storage.RemoteLogMetadataManager
-
Returns total size of the log for the given leader epoch in remote storage.
- RemotePartitionDeleteMetadata - Class in org.apache.kafka.server.log.remote.storage
-
This class represents the metadata about the remote partition.
- RemotePartitionDeleteMetadata(TopicIdPartition, RemotePartitionDeleteState, long, int) - Constructor for class org.apache.kafka.server.log.remote.storage.RemotePartitionDeleteMetadata
-
Creates an instance of this class with the given metadata.
- RemotePartitionDeleteState - Enum in org.apache.kafka.server.log.remote.storage
-
This enum indicates the deletion state of the remote topic partition.
- RemoteResourceNotFoundException - Exception in org.apache.kafka.server.log.remote.storage
-
Exception thrown when a resource is not found on the remote storage.
- RemoteResourceNotFoundException(String) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteResourceNotFoundException
-
- RemoteResourceNotFoundException(Throwable) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteResourceNotFoundException
-
- RemoteResourceNotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteResourceNotFoundException
-
- RemoteStorageException - Exception in org.apache.kafka.server.log.remote.storage
-
Exception thrown when there is a remote storage error.
- RemoteStorageException(String) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteStorageException
-
- RemoteStorageException(String, Throwable) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteStorageException
-
- RemoteStorageException(Throwable) - Constructor for exception org.apache.kafka.server.log.remote.storage.RemoteStorageException
-
- RemoteStorageManager - Interface in org.apache.kafka.server.log.remote.storage
-
This interface provides the lifecycle of remote log segments that includes copy, fetch, and delete from remote
storage.
- RemoteStorageManager.IndexType - Enum in org.apache.kafka.server.log.remote.storage
-
Type of the index file.
- RemoteStorageMetrics - Class in org.apache.kafka.server.log.remote.storage
-
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.
- RemoteStorageMetrics() - Constructor for class org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics
-