public interface KafkaRestorePartitionHandle
Modifier and Type | Method and Description |
---|---|
Optional<File> |
ftpsFile(String topic,
int partition)
The partition's ftps file.
|
int |
leaderReplica(String topic,
int partition)
The brokerId corresponding leader of the given replica.
|
int |
preChecksForRestore(String topic,
int partition)
Validates if restore can be started on the given partition
|
TierRecordMetadataResponse |
setFenceTierTopicPartition(String topic,
int partition)
Fence tier partition state.
|
TierRecordMetadataResponse |
setForceRestoreTierPartition(String topic,
int partition,
long startOffset,
long endOffset,
String contentHash,
byte checksumAlgorithm)
Force restore tier partition state.
|
TierRecordMetadataResponse |
setUnfreezeLogStartOffset(String topic,
int partition)
Unfreeze log start offset.
|
TierPartitionStateResponse |
tierPartitionStatus(String topic,
int partition)
The tierPartitionStatus corresponding to this broker.
|
int |
validateLogRange(String topic,
int partition,
long startOffset,
long endOffset)
Validate if the log view spans across given start and end offset.
|
int leaderReplica(String topic, int partition)
TierPartitionStateResponse tierPartitionStatus(String topic, int partition)
TierRecordMetadataResponse setFenceTierTopicPartition(String topic, int partition)
TierRecordMetadataResponse setForceRestoreTierPartition(String topic, int partition, long startOffset, long endOffset, String contentHash, byte checksumAlgorithm)
TierRecordMetadataResponse setUnfreezeLogStartOffset(String topic, int partition)
int validateLogRange(String topic, int partition, long startOffset, long endOffset)
int preChecksForRestore(String topic, int partition)