Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
SEGMENT_DELETE_COMPLETE |
3 |
public static final byte |
SEGMENT_DELETE_INITIATE |
2 |
public static final byte |
SEGMENT_FENCED |
4 |
public static final byte |
SEGMENT_UPLOAD_COMPLETE |
1 |
public static final byte |
SEGMENT_UPLOAD_INITIATE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COMPARISON_TOOL_INPUT |
"input.json" |
public static final java.lang.String |
COMPARISON_TOOL_INPUT_DOC |
"The path to a json file to be accepted as the input to the tool" |
public static final java.lang.String |
COMPARISON_TOOL_OUTPUT |
"output.json" |
public static final java.lang.String |
COMPARISON_TOOL_OUTPUT_DOC |
"The path to a json file where the tool will generate the output" |
public static final java.lang.String |
TIER_PROPERTIES_CONF_FILE_CONFIG |
"tier.config" |
public static final java.lang.String |
TIER_PROPERTIES_CONF_FILE_DOC |
"The path to a configuration file containing the required properties" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
FILE_FENCE_TARGET_PARTITIONS_CONFIG |
"file-fence-target-partitions" |
public static final java.lang.String |
FILE_FENCE_TARGET_PARTITIONS_DOC |
"The path to a file containing non-empty list of target tiered partitions to be fenced by the tool. The format of the file is a newline separated list of information. Each line is a comma-separated value (CSV) containing information about a single tiered TopicIdPartition in the following format: \'<tiered_partition_topic_ID_base64_encoded>:<tiered_partition_topic_name>-<tiered_partition_name>\'." |
public static final java.lang.String |
OUTPUT_CONFIG |
"output.json" |
public static final java.lang.String |
OUTPUT_CONFIG_DOC |
"The path where JSON containing the fenced partitions, and fence message offsets/UUIDs will be written to." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
RESTORE_INPUT_COMPARATOR_CONFIG |
"comparator.json" |
public static final java.lang.String |
RESTORE_INPUT_COMPARATOR_DOC |
"JSON input file generated by kafka.tier.tools.TierMetadataComparator and reviewed by an administrator. This file contains paths to partitions and replica TierPartitionState(s) to choose to restore." |
public static final java.lang.String |
RESTORE_INPUT_RAW_CONFIG |
"raw.json" |
public static final java.lang.String |
RESTORE_INPUT_RAW_DOC |
"JSON input file. This file contains paths to partitions and replica TierPartitionState(s) to choose to restore." |
public static final java.lang.String |
RESTORE_OUTPUT_CONFIG |
"output.json" |
public static final java.lang.String |
RESTORE_OUTPUT_DOC |
"Path for output file where recovery information will be emitted, including TierPartitionForceRestore metadata." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BROKER_WORKDIR_LIST |
"confluent.tier.recovery.broker.workdir.list" |
public static final java.lang.String |
DUMP_EVENTS |
"confluent.tier.recovery.dump.events" |
public static final java.lang.String |
MATERIALIZE |
"confluent.tier.recovery.materialize" |
public static final java.lang.String |
VALIDATE |
"confluent.tier.recovery.validate" |
public static final java.lang.String |
WORKING_DIR |
"confluent.tier.recovery.working.dir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BOOTSTRAP_SERVER_CONFIG |
"bootstrap-server" |
public static final java.lang.String |
BOOTSTRAP_SERVER_DOC |
"The broker server and port string in form host:port" |
public static final java.lang.String |
CLUSTER_ID |
"cluster-id" |
public static final java.lang.String |
CLUSTER_ID_DOC |
"The zk cluster ID for which the tool will connect" |
public static final java.lang.String |
DUMP_EVENTS |
"dump-events" |
public static final java.lang.String |
DUMP_EVENTS_DOC |
"dumps the tier state topic\'s events on std out. By default its turned to be true. If chosen false it will still dump everty 1000th events for trackinglong runs." |
public static final java.lang.String |
DUMP_METADATA |
"dump-metadata" |
public static final java.lang.String |
DUMP_METADATA_DOC |
"dump-metadata will dump entire metadata of tier topic partitions on the std output." |
public static final java.lang.String |
DUMP_METADATA_HEADER |
"dump-metadata-header" |
public static final java.lang.String |
DUMP_METADATA_HEADER_DOC |
"dump-metadata-header will dump only header of the tier topic partition\'s state." |
public static final java.lang.String |
EMPTY_UUID_STR |
"00000000-0000-0000-0000-000000000000" |
public static final java.lang.String |
END_OFFSET |
"end-offset" |
public static final java.lang.String |
END_OFFSET_DOC |
"end offset from where the events will be processed. This will be ignored if tier-topic-partition is not set." |
public static final java.lang.String |
MATERIALIZE |
"materialize" |
public static final java.lang.String |
MATERIALIZE_DOC |
"if set, then only materialize the events to generate state file." |
public static final java.lang.String |
METADATA_STATES_DIR |
"metadata-states-dir" |
public static final java.lang.String |
METADATA_STATES_DIR_DOC |
"data directory of kafka, to pull tier topic state files." |
public static final java.lang.String |
SNAPSHOT_STATES_FILES |
"snapshot-states-files" |
public static final java.lang.String |
SNAPSHOT_STATES_FILES_DOC |
"If not set then it\'s expected that the state files are already saved in the snapshot folder." |
public static final java.lang.String |
SRC_PARTIITON_DOC |
"source partition id. If selected, all the processing will be limited for this partition." |
public static final java.lang.String |
SRC_PARTITION |
"source-partition" |
public static final java.lang.String |
SRC_TOPIC_DOC |
"source topic id. If selected all the processing will be limited for this id" |
public static final java.lang.String |
SRC_TOPIC_ID |
"source-topic-id" |
public static final java.lang.String |
START_OFFSET |
"start-offset" |
public static final java.lang.String |
START_OFFSET_DOC |
"start offset from where the events will be processed.This will be ignored if tier-topic-partition is not set." |
public static final java.lang.String |
TIER_STATE_TOPIC_PARTITION |
"tier-state-topic-partition" |
public static final java.lang.String |
TIER_STATE_TOPIC_PARTITION_DOC |
"tier topic partition. If selected all the processing will be limited from this partition." |
public static final java.lang.String |
TIER_STORAGE_OFFSET_VALIDATION |
"validate-tier-storage-offset" |
public static final java.lang.String |
TIER_STORAGE_OFFSET_VALIDATION_DOC |
"verifies that the offsets mentioned in the metadata is present in the segment file in object store" |
public static final java.lang.String |
TIER_STORAGE_VALIDATION |
"validate-tier-storage" |
public static final java.lang.String |
TIER_STORAGE_VALIDATION_DOC |
"verifies the object presence in the tier object store in terms of the object ID in the metadata" |
public static final long |
UNKNOWN_OFFSET |
-2L |
public static final java.lang.String |
WORKING_DIR |
"working-dir" |
public static final java.lang.String |
WORKING_DIR_DOC |
"working-dir is the directory path where the tool will generate its data" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
REMATERIALIZED_REPLICA_ID |
"rematerialized" |