public class TierMetadataComparator extends Object implements AutoCloseable
The way to run this tool is: $ bin/kafka-run-class.sh kafka.tier.tools.TierMetadataComparator --tier.config=/path/to/input.properties --input.json=/path/to/fencing.json --output.json=/path/to/output.json
Modifier and Type | Field and Description |
---|---|
static List<String> |
REQUIRED_PROPERTIES |
Constructor and Description |
---|
TierMetadataComparator(org.apache.kafka.common.utils.Time time,
Properties props,
List<FenceEventInfo> fenceEvents,
Path outputJsonFile,
kafka.utils.Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
void |
close()
As part of the closeable contract, this method will cleanup all the open resources such as backend stores
as well as cancel any long-running existing verification tasks
|
static void |
main(String[] args) |
void |
run()
The core logic of the Comparator tool can be broken down into the following 4 steps:
1.
|
public TierMetadataComparator(org.apache.kafka.common.utils.Time time, Properties props, List<FenceEventInfo> fenceEvents, Path outputJsonFile, kafka.utils.Scheduler scheduler)
public void run()
public void close()
close
in interface AutoCloseable