public class TierMetadataComparator
extends java.lang.Object
implements java.lang.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 java.util.List<java.lang.String> |
REQUIRED_PROPERTIES |
Constructor and Description |
---|
TierMetadataComparator(java.util.Properties props,
java.util.List<FenceEventInfo> fenceEvents,
java.nio.file.Path outputJsonFile) |
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(java.lang.String[] args) |
void |
run()
The core logic of the Comparator tool can be broken down into the following 4 steps:
1.
|
public static final java.util.List<java.lang.String> REQUIRED_PROPERTIES
public TierMetadataComparator(java.util.Properties props, java.util.List<FenceEventInfo> fenceEvents, java.nio.file.Path outputJsonFile)
public void run()
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public void close()
close
in interface java.lang.AutoCloseable