public interface TierMetadataRecoveryHandle
Modifier and Type | Method and Description |
---|---|
TierTopicHeadDataLossDetectionResponse |
maybeDetectDataLossInTierTopicHead(TierTopicHeadDataLossDetectionRequest request,
long timeoutMs) |
TierRecoveryDataUploadResult |
maybeGetTierRecoveryDataUploadJobResult(UUID jobId) |
UUID |
maybeInitiateTierRecoveryDataUpload(Set<org.apache.kafka.common.TopicIdPartition> topicIdPartitions,
String identifier,
int numThreads) |
Map<String,Set<Integer>> |
maybeRewindTierTopicConsumer(Optional<Map<Integer,Map<Long,Optional<Integer>>>> partitionToPositionOpt,
boolean forceStop,
byte policy) |
Map<String,Set<Integer>> maybeRewindTierTopicConsumer(Optional<Map<Integer,Map<Long,Optional<Integer>>>> partitionToPositionOpt, boolean forceStop, byte policy)
UUID maybeInitiateTierRecoveryDataUpload(Set<org.apache.kafka.common.TopicIdPartition> topicIdPartitions, String identifier, int numThreads)
TierRecoveryDataUploadResult maybeGetTierRecoveryDataUploadJobResult(UUID jobId)
TierTopicHeadDataLossDetectionResponse maybeDetectDataLossInTierTopicHead(TierTopicHeadDataLossDetectionRequest request, long timeoutMs)