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 |
setFenceTierTopicPartition(String topic,
int partition)
Fence tier partition state.
|
int |
setForceRestoreTierPartition(String topic,
int partition,
long startOffset,
long endOffset,
String contentHash)
Force restore tier partition state.
|
int |
setUnfreezeLogStartOffset(String topic,
int partition)
Unfreeze log start offset.
|
long |
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)
long tierPartitionStatus(String topic, int partition)
int setFenceTierTopicPartition(String topic, int partition)
int setForceRestoreTierPartition(String topic, int partition, long startOffset, long endOffset, String contentHash)
int setUnfreezeLogStartOffset(String topic, int partition)
int validateLogRange(String topic, int partition, long startOffset, long endOffset)