public class TierPartitionStateRestoreTrigger
extends Object
A tool that injects PartitionForceRestore events into TierTopic for a provided list of
TopicIdPartition. This is helpful in restoring a blessed TierPartitionState.
There are two separate ways to use this tool, as described below:
(1) Raw input mode:
We pass the output of the fencing command and a path to the root directory containing
tier states to be restored into the restore tool.
$> bin/kafka-run-class.sh \
kafka.tier.tools.TierPartitionStateRestoreTrigger \
--tier.config /path/to/config.properties \
--fence.json /path/to/fence_output.json
--restore.tier.state.root.dir /path/to/restore_tier_state_root_dir
--output.json /path/to/restored.json
(2) Comparator input mode:
We pass the output of the TierMetadataComparator tool directly into the restore tool.
$> bin/kafka-run-class.sh \
kafka.tier.tools.TierPartitionStateRestoreTrigger \
--tier.config /path/to/config.properties \
--comparator.json /path/to/comparator.json
--output.json /path/to/restored.json