Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LATEST_VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
INPUT_PATH_CONFIG |
"path" |
public static final String |
INPUT_PATH_DOC |
"The path to durability db data, e.g., /mnt/data/data0/logs/" |
public static final String |
PARTITION_CONFIG |
"partition" |
public static final String |
PARTITION_DOC |
"The partition for which TopicState is requested, e.g., 1" |
public static final String |
TOPIC_CONFIG |
"topic" |
public static final String |
TOPIC_DOC |
"The topic for which TopicState is requested, e.g., test" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
2 |
public static final short |
LOWEST_SUPPORTED_VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
4 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
4 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
1 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
4 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
0 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
1 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
1 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
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 short |
SUPER_BLOCK_LENGTH_ADLER |
512 |
public static final short |
SUPER_BLOCK_LENGTH_NO_CHECKSUM |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMPARISON_TOOL_INPUT |
"input.json" |
public static final String |
COMPARISON_TOOL_INPUT_DOC |
"The path to a json file to be accepted as the input to the tool" |
public static final String |
COMPARISON_TOOL_OUTPUT |
"output.json" |
public static final String |
COMPARISON_TOOL_OUTPUT_DOC |
"The path to a json file where the tool will generate the output" |
public static final String |
FENCE_TARGET_PARTITIONS_CONFIG_FILE_FORMAT |
"<tiered_partition_topic_ID_base64_encoded>:<tiered_partition_topic_name>-<tiered_partition_number> <freeze_merged_log_start_offset>" |
public static final String |
TIER_PROPERTIES_CONFIG_FILE |
"tier.config" |
public static final String |
TIER_PROPERTIES_CONFIG_FILE_DOC |
"The path to a configuration file containing the required properties" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FENCE_TARGET_PARTITIONS_CONFIG_FILE |
"file-fence-target-partitions" |
public static final String |
FENCE_TARGET_PARTITIONS_CONFIG_FILE_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_number> <freeze_merged_log_start_offset> where `freeze_merged_log_start_offset` is a boolean indicating that log start offset must be frozen as part of fencing the partition." |
public static final String |
FENCE_TRIGGER_OUTPUT_FILE |
"output.json" |
public static final String |
FENCE_TRIGGER_OUTPUT_FILE_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 String |
RESTORE_INPUT_COMPARATOR_CONFIG |
"comparator.json" |
public static final 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 String |
RESTORE_INPUT_RAW_CONFIG |
"raw.json" |
public static final 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 String |
RESTORE_OUTPUT_CONFIG |
"output.json" |
public static final 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 String |
UNFREEZE_LOG_START_OFFSET_INPUT |
"restore.json" |
public static final String |
UNFREEZE_LOG_START_OFFSET_INPUT_DOC |
"Json input file generated by kafka.tier.tools.TierPartitionStateRestoreTrigger tool. This file contains information about the TierPartitionForceRestore event injected by the TierPartitionStateRestoreTrigger tool and tier partition states\' comparison data created earlier by the kafka.tier.tools.TierMetadataComparator tool." |
public static final String |
UNFREEZE_LOG_START_OFFSET_OUTPUT |
"output.json" |
public static final String |
UNFREEZE_LOG_START_OFFSET_OUTPUT_DOC |
"Path to the output file where information about the TierPartitionUnfreezeLogStartOffset event will be saved." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BROKER_WORKDIR_LIST |
"confluent.tier.recovery.broker.workdir.list" |
public static final String |
DUMP_EVENTS |
"confluent.tier.recovery.dump.events" |
public static final String |
MATERIALIZE |
"confluent.tier.recovery.materialize" |
public static final String |
VALIDATE |
"confluent.tier.recovery.validate" |
public static final String |
WORKING_DIR |
"confluent.tier.recovery.working.dir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BOOTSTRAP_SERVER_CONFIG |
"bootstrap-server" |
public static final String |
BOOTSTRAP_SERVER_DOC |
"The broker server and port string in form host:port" |
public static final String |
CHECKSUM_ENABLED |
"checksum-enabled" |
public static final String |
CHECKSUM_ENABLED_DOC |
"should be set to true if checksum is enabled for the tier state file false otherwise." |
public static final String |
CLUSTER_ID |
"cluster-id" |
public static final String |
CLUSTER_ID_DOC |
"The zk cluster ID for which the tool will connect" |
public static final String |
DUMP_EVENTS |
"dump-events" |
public static final 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 String |
DUMP_METADATA |
"dump-metadata" |
public static final String |
DUMP_METADATA_DOC |
"dump-metadata will dump entire metadata of tier topic partitions on the std output." |
public static final String |
DUMP_METADATA_HEADER |
"dump-metadata-header" |
public static final String |
DUMP_METADATA_HEADER_DOC |
"dump-metadata-header will dump only header of the tier topic partition\'s state." |
public static final String |
EMPTY_UUID_STR |
"00000000-0000-0000-0000-000000000000" |
public static final String |
END_OFFSET |
"end-offset" |
public static final 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 String |
MATERIALIZE |
"materialize" |
public static final String |
MATERIALIZE_DOC |
"if set, then only materialize the events to generate state file." |
public static final String |
METADATA_STATES_DIR |
"metadata-states-dir" |
public static final String |
METADATA_STATES_DIR_DOC |
"data directory of kafka, to pull tier topic state files." |
public static final String |
SNAPSHOT_STATES_FILES |
"snapshot-states-files" |
public static final 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 String |
SRC_PARTIITON_DOC |
"source partition id. If selected, all the processing will be limited for this partition." |
public static final String |
SRC_PARTITION |
"source-partition" |
public static final String |
SRC_TOPIC_DOC |
"source topic id. If selected all the processing will be limited for this id" |
public static final String |
SRC_TOPIC_ID |
"source-topic-id" |
public static final String |
START_OFFSET |
"start-offset" |
public static final 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 String |
TIER_STATE_TOPIC_PARTITION |
"tier-state-topic-partition" |
public static final String |
TIER_STATE_TOPIC_PARTITION_DOC |
"tier topic partition. If selected all the processing will be limited from this partition." |
public static final String |
TIER_STORAGE_OFFSET_VALIDATION |
"validate-tier-storage-offset" |
public static final 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 String |
TIER_STORAGE_VALIDATION |
"validate-tier-storage" |
public static final 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 String |
WORKING_DIR |
"working-dir" |
public static final 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 String |
REMATERIALIZED_REPLICA_ID |
"rematerialized" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
ADLER_SUPER_BLOCK_LENGTH_MAX |
4096 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
NO_CHECKSUM_SUPER_BLOCK_LENGTH_DEFAULT |
0 |