public class TierMetadataValidator
extends java.lang.Object
TierMetadataValidator: Tool to validate the materialization of the tier topic partition's materialization states. The
approach is that for given kafka data path, the tool will snapshot all the TierPartition state's file to its working
directory and then after computing the map of topic partition to max consumer tier topic partition's offset, the
expected state is computed after consuming the relevant tier topic partition's events. Finally the expected state is
compared against the snapshot one.
Usage
# Validate all the local state file on the existing broker with optional workdir and path to metadata-states-dir.
$KAFKA_BIN/kafka-tier-materialization-validator.sh --metadata-states-dir= --working-dir=/tmp/work-dir
TBD : Support flag to directly validate state files in given snapshot folder. This will be used for periodical
validator/scrubber which may run from separate system and may call this after collecting all state files.