This tool is for clearing tiered data info in FTPS file.
It will update FTPS by:
1. change all segments in SEGMENT_UPLOAD_INITIATE, SEGMENT_UPLOAD_COMPLETE or SEGMENT_DELETE_INITIATE state to SEGMENT_FENCED state.
2. reset header fields to:
startOffset = -1,
endOffset = -1,
errorOffsetAndEpoch = OffsetAndEpoch.EMPTY,
lastRestoredOffsetAndEpoch = OffsetAndEpoch.EMPTY,
compactDirtyStartOffset = -1,
lastCompactStats = CompactStats.EMPTY,
accumulatedCompactStats = CompactStats.EMPTY
The output FTPS file is placed under the same folder as the input FTPS file.
SAMPLE USAGE:
$> bin/kafka-run-class.sh kafka.restore.ResetTierPartitionState \
--topic
\
--partition \
--ftps