Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ACTIVE_COLLECTOR |
"active-collector" |
public static final String |
ACTIVE_COLLECTOR_DOC |
"Reports 1 if the catalog metadata collector is active, 0 otherwise." |
public static final String |
CACHED_TOPICS_TOTAL |
"cached-topics-total" |
public static final String |
CACHED_TOPICS_TOTAL_DOC |
"Number of topics cached in the metadata collector." |
public static final String |
COLLECTOR_EVENT_HANDLE_ERROR |
"num-collector-event-handle-error" |
public static final String |
COLLECTOR_EVENT_HANDLE_ERROR_DOC |
"Number of error during collector events handling" |
public static final String |
DELTA_EVENT_EMIT |
"num-delta-event-emit" |
public static final String |
DELTA_EVENT_EMIT_DOC |
"The number of delta create, update and delete events emitted." |
public static final String |
GROUP_NAME |
"catalog-metrics" |
public static final String |
SNAPSHOT_EMITTING_DELAY_MS |
"snapshot-emitting-delay-ms" |
public static final String |
SNAPSHOT_EMITTING_DELAY_MS_DOC |
"Delay between each snapshot emitted (include snapshot taken time) in milliseconds." |
public static final String |
SNAPSHOT_EVENT_EMIT |
"num-snapshot-event-emit" |
public static final String |
SNAPSHOT_EVENT_EMIT_DOC |
"Number of snapshot events emitted" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CATALOG_TOPIC_METADATA_SUBJECT |
"catalog-topic-metadata-exporter" |
public static final String |
TOPIC_DELTA |
"TOPIC_DELTA" |
public static final String |
TOPIC_SNAPSHOT |
"TOPIC_SNAPSHOT" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CACHE_BUILD_EVENT_TAG |
"CACHE_BUILD_EVENT" |
public static final String |
SNAPSHOT_EVENT_TAG |
"SNAPSHOT_EVENT" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LATEST_VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AUDIT_JOB_ID |
"job-id" |
public static final String |
AUDIT_JOB_ID_DOC |
"Retrieve status for given audit job id" |
public static final String |
BROKER_ID |
"broker-id" |
public static final String |
BROKER_ID_DOC |
"Runs audit job on all partitions for specified broker" |
public static final String |
CLUSTER |
"cluster" |
public static final String |
CLUSTER_DOC |
"Runs audit job for all brokers in the cluster" |
public static final String |
COMPACTION_CHECK |
"compaction-check" |
public static final String |
COMPACTION_CHECK_DOC |
"Performs compaction check if set to true" |
public static final String |
COMPACTION_CHECK_NEEDED |
"compaction_check_needed" |
public static final String |
DESCRIPTION |
"Start audit jobs for given Topic and Partitions" |
public static final String |
DETAIL |
"detail" |
public static final String |
DETAIL_DOC |
"Returns detail status if set to true" |
public static final String |
FORCE |
"force" |
public static final String |
FORCE_DOC |
"Stops the existing job and starts a new one" |
public static final String |
FORCE_START |
"force_start" |
public static final String |
GET_AUDIT_JOB_STATUS_URI_PATH |
"/v1/audit/get-audit-job-status" |
public static final int |
HTTP_MAX_RETRIES |
2 |
public static final String |
JOB_ID |
"job_id" |
public static final String |
PARTITION |
"partition" |
public static final String |
PARTITION_DOC |
"Runs audit job on specified partition" |
public static final String |
RUN_AUDIT |
"run-audit" |
public static final String |
RUN_AUDIT_DOC |
"Starts an audit job" |
public static final String |
START_AUDIT_JOB_URI_PATH |
"/v1/audit/start-audit-job" |
public static final String |
STATUS |
"status" |
public static final String |
STATUS_DOC |
"Gets audit job status for entire cluster" |
public static final String |
STOP |
"stop" |
public static final String |
STOP_AUDIT_JOB_URI_PATH |
"/v1/audit/stop-audit-job" |
public static final String |
STOP_DOC |
"Stops any currently running audit jobs in the cluster" |
public static final String |
TOPIC_NAME |
"topic-name" |
public static final String |
TOPIC_NAME_DOC |
"Runs audit job for all partitions for specified topic name" |
public static final String |
TOPIC_PARTITION_FILE_CONFIG |
"topic-partition-file" |
public static final String |
TOPIC_PARTITION_FILE_DOC |
"Name of the file contains the list of topic partitions to be audited" |
public static final String |
TOPIC_PARTITIONS_MAP |
"topic_partitions_map" |
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 String |
CONFIG |
"config" |
public static final String |
CONFIG_DOC |
"config of topic partition" |
public static final String |
EPOCH |
"epoch" |
public static final String |
EPOCH_DOC |
"epoch of event" |
public static final String |
HWM |
"hwm" |
public static final String |
HWM_DOC |
"high watermark" |
public static final String |
PARTITION |
"partition" |
public static final String |
PARTITION_DOC |
"partition number" |
public static final String |
START_OFFSET |
"start offset" |
public static final String |
START_OFFSET_DOC |
"start offset of event" |
public static final String |
TOPIC |
"topic" |
public static final String |
TOPIC_DOC |
"topic name" |
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 |
0 |
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 |
0 |
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 |
2 |
public static final short |
LOWEST_SUPPORTED_VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
3 |
public static final short |
LOWEST_SUPPORTED_VERSION |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
HIGHEST_SUPPORTED_VERSION |
3 |
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 |
3 |
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 |
0 |
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 String |
FTPS_FILE_CONFIG |
"ftps" |
public static final String |
OUTPUT_FTPS_FILE_PREFIX |
"cleared." |
public static final String |
PARTITION_CONFIG |
"partition" |
public static final String |
TOPIC_CONFIG |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BUCKET_NAME |
"restore.bucket.name" |
public static final String |
CLOUD_PROVIDER |
"restore.cloud.provider" |
public static final String |
CLUSTER_ID_CONFIG |
"clusterid" |
public static final String |
KAFKA_BOOTSTRAP_PORT_CONFIG |
"kafka-bootstrap-port" |
public static final String |
KAFKA_INTERNAL_REST_SERVER_PORT_CONFIG |
"internal-rest-port" |
public static final int |
MAX_KAFKA_CONNECTION_POOL_SIZE |
20 |
public static final int |
OBJECT_STORE_POOL_SIZE_MULTIPLIER |
10 |
public static final String |
PARTITION_FILE_CONFIG |
"partition-file" |
public static final String |
RESTORE_PARALLELISM |
"RESTORE_PARALLELISM" |
public static final int |
RESTORE_REST_SERVER_PORT |
9090 |
public static final String |
ZOOKEEPER_CONFIG |
"zookeeper.connect" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RESTORE_BYTES_FAILED |
"RestoreBytesFailed" |
public static final String |
RESTORE_BYTES_SUCCESS |
"RestoreBytesSuccess" |
public static final String |
RESTORE_END_WITH_FAILURE |
"RestoreEndWithFailure" |
public static final String |
RESTORE_END_WITH_SUCCESS |
"RestoreEndWithSuccess" |
public static final String |
RESTORE_EVENTS_COMMIT_AND_SWAP_COUNT |
"RestoreEventsCommitAndSwapCount" |
public static final String |
RESTORE_EVENTS_FORCE_RESTORE_OR_UNFREEZE_COUNT |
"RestoreEventsForceRestoreOrUnfreezeCount" |
public static final String |
RESTORE_EVENTS_REPLAY_FAILED_COUNT |
"RestoreEventsReplayFailedCount" |
public static final String |
RESTORE_EVENTS_REPLAYED_COUNT |
"RestoreEventsReplayedCount" |
public static final String |
RESTORE_EVENTS_SEGMENTS_TO_DELETE_COUNT |
"RestoreEventsSegmentsToDeleteCount" |
public static final String |
RESTORE_EVENTS_SEGMENTS_TO_RESTORE_COUNT |
"RestoreEventsSegmentsToRestoreCount" |
public static final String |
RESTORE_FETCH_FTPS_FAILURES |
"RestoreFetchFtpsFailures" |
public static final String |
RESTORE_FETCH_FTPS_MS |
"RestoreFetchFtpsMs" |
public static final String |
RESTORE_FETCH_TIER_TOPIC_SNAPSHOT_MS |
"RestoreFetchTierTopicSnapshotMs" |
public static final String |
RESTORE_FILES_FAILED |
"RestoreFilesFailed" |
public static final String |
RESTORE_FILES_SUCCESS |
"RestoreFilesSuccess" |
public static final String |
RESTORE_IN_PROGRESS |
"RestoreInProgress" |
public static final String |
RESTORE_LIST_VERSIONS_FAILURES |
"RestoreListVersionsFailures" |
public static final String |
RESTORE_LIST_VERSIONS_MS |
"RestoreListVersionsMs" |
public static final String |
RESTORE_OBJECT_COPY_FAILURES |
"RestoreObjectCopyFailures" |
public static final String |
RESTORE_OBJECT_COPY_MS |
"RestoreObjectCopyMs" |
public static final String |
RESTORE_OVERALL_RATE_BYTES_PER_SECOND |
"RestoreOverallRate" |
public static final String |
RESTORE_PARTITIONS_COMPLETED_COUNT |
"RestorePartitionsCompletedCount" |
public static final String |
RESTORE_PARTITIONS_FAILED_COUNT |
"RestorePartitionsFailedCount" |
public static final String |
RESTORE_PARTITIONS_IN_PROGRESS_COUNT |
"RestorePartitionsInProgressCount" |
public static final String |
RESTORE_PARTITIONS_WAITING_COUNT |
"RestorePartitionsWaitingCount" |
public static final String |
RESTORE_SEGMENTS_FAILED |
"RestoreSegmentsFailed" |
public static final String |
RESTORE_SEGMENTS_SUCCESS |
"RestoreSegmentsSuccess" |
public static final String |
RESTORE_STARTED |
"RestoreStarted" |
public static final String |
RESTORE_TIME_TO_BUILD_FTPS_STATES_FROM_SNAPSHOTS_MS |
"RestoreTimeToBuildFtpsStatesFromSnapshots" |
public static final String |
RESTORE_TIME_TO_REPLAY_EVENTS_MS |
"RestoreTimeToReplayEvents" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KAFKA_CLUSTER_ID |
"kafka.cluster.id" |
public static final String |
KAFKA_NODE_ID |
"kafka.node.id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLEANUP_POLICY |
"cleanup.policy" |
public static final String |
COMPACT |
"compact" |
public static final String |
RETENTION_MS |
"retention.ms" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTENT_HASH_PARAM_NAME |
"content_hash" |
public static final int |
DEFAULT_CORES_TO_POOL_SIZE_RATIO |
101 |
public static final String |
DRY_RUN |
"dry_run" |
public static final String |
END_OFFSET_PARAM_NAME |
"log_end_offset" |
public static final String |
FENCE_EVENT_URI_PATH |
"/v1/restore/fence" |
public static final String |
FETCH_FTPS_URI_PATH |
"/v1/restore/ftps" |
public static final String |
FORCE_RESTORE_EVENT_URI_PATH |
"/v1/restore/restore" |
public static final int |
HTTP_MAX_RETRIES |
10 |
public static final int |
KAFKA_MAX_RETRIES |
20 |
public static final int |
OBJECT_STORE_REQUEST_MAX_RETRIES |
10 |
public static final String |
PARTITION_PARAM_NAME |
"partition" |
public static final int |
PARTITION_STATUS_INVALID |
-1 |
public static final String |
PRE_CONDITION_CHECK_URI_PATH |
"/v1/restore/pre-checks" |
public static final String |
START_OFFSET_PARAM_NAME |
"log_start_offset" |
public static final String |
TIER_PARTITION_STATUS_URI_PATH |
"/v1/restore/tier-state" |
public static final String |
TOPIC_PARAM_NAME |
"topic_name" |
public static final String |
TOPIC_PARTITION |
"topic_partition" |
public static final String |
TOPICS |
"topics" |
public static final String |
UNFREEZE_EVENT_URI_PATH |
"/v1/restore/unfreeze" |
public static final String |
VALIDATE_LOG_RANGE_URI_PATH |
"/v1/restore/validate-log-range" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
MAX_SEGMENTS_PER_BATCH |
200 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
DEFAULT_KEY_PREFIX |
"" |
protected static final String |
TIER_TOPIC_NAME |
"_confluent-tier-state" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
TIER_TOPIC_NAME |
"_confluent-tier-state" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
META_FTPS_FILE_PATH |
"ftps_file_path" |
public static final String |
META_FTPS_FOR_RESTORE |
"ftps_for_restore" |
public static final String |
META_NEW_FTPS_CONTENT_HASH |
"ftps_content_hash" |
public static final String |
META_NEW_FTPS_LOG_END_OFFSET |
"ftps_log_end_offset" |
public static final String |
META_NEW_FTPS_LOG_START_OFFSET |
"ftps_log_start_offset" |
public static final String |
META_RESTORE_SEGMENT_STATE_MAP |
"restore_segment_map" |
public static final String |
META_RESTORE_SEGMENT_STATE_MAP_SIZE |
"restore_segment_map_size" |
public static final String |
META_SEGMENT_COUNT_RECONCILED |
"segment_count_reconciled" |
public static final String |
PARTITION |
"partition" |
public static final String |
PARTITION_LEADER |
"partition_leader" |
public static final String |
PARTITION_REPLICAS |
"partition_replicas" |
public static final String |
PARTITION_RESTORE_CONTEXT |
"partition_restore_context" |
public static final String |
RESTORE_FROM_TIMESTAMP |
"restore_from_timestamp" |
public static final String |
REVERT_COMPACTION_SINCE_TIMESTAMP |
"revert_compaction_since_timestamp" |
public static final String |
STATE_TRANSITION_LOGS |
"state_transition_logs" |
public static final String |
TOPIC |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MESSAGE_RESPONSE |
"message_response" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATE_PATTERN |
"yyyyMMdd" |
public static final int |
DEFAULT_CLM_RUN_FREQUENCY_IN_HOURS |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_BATCH_SIZE_TO_SUBMIT |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LIFECYCLE_MANAGER_STATE_CURRENT_VERSION |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
CURRENT_VERSION |
1 |
public static final byte |
VERSION_V1 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
CURRENT_VERSION |
1 |
public static final byte |
VERSION_V1 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_STATE_CHANGE_TIMESTAMP |
9223372036854775807L |
public static final int |
UNKNOWN_VIRTUAL_OFFSET |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
CURRENT_VERSION |
1 |
public static final byte |
VERSION_V1 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
CURRENT_VERSION |
2 |
public static final byte |
VERSION_V1 |
1 |
public static final byte |
VERSION_V2 |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
INVALID |
-1 |
public static final byte |
SEGMENT_COMPACTED |
5 |
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 String |
ACTIVE_STATE_INDICATOR_PREFIX |
"ActiveIndicator" |
public static final String |
CONSUMER_LAG_METRIC_PREFIX |
"ConsumerLag" |
public static final String |
FAILURE_METRIC_PREFIX |
"FailureTotal" |
public static final String |
TTPS_SNAPSHOT_UPLOADED_PREFIX |
"UploadedTotal" |
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 |
TIER_PARTITION_STATE_METADATA_SNAPSHOTS_DIR |
"snapshots" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ENTRY_LENGTH_SIZE |
2 |
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 |
BROKER_ID |
"broker-id" |
public static final String |
BROKER_ID_DOC |
"The zk broker ID for which the tool will connect" |
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 |
CONSUMER_CONFIG |
"consumer-config" |
public static final String |
CONSUMER_CONFIG_DOC |
"Additional KafkaConsumer configuration properties file." |
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_COMPACT_ENABLED |
"tier-compact-feature-flag" |
public static final String |
TIER_COMPACT_ENABLED_DOC |
"should be set to true if tier compaction is enabled for this cluster." |
public static final String |
TIER_PARTITION_STATE_CLEANUP_DELAY |
"tier-partition-state-cleanup-delay" |
public static final String |
TIER_PARTITION_STATE_CLEANUP_DELAY_DOC |
"FTPS cleanup only removes deleted segment entries which are deleted this amount of time ago. It is in millisecond time unit." |
public static final String |
TIER_PARTITION_STATE_CLEANUP_ENABLED |
"tier-partition-state-cleanup-feature-flag" |
public static final String |
TIER_PARTITION_STATE_CLEANUP_ENABLED_DOC |
"should be set to true if tier state file cleanup is enabled." |
public static final String |
TIER_PARTITION_STATE_CLEANUP_INTERVAL |
"tier-partition-state-cleanup-interval" |
public static final String |
TIER_PARTITION_STATE_CLEANUP_INTERVAL_DOC |
"FTPS cleanup is triggered periodically during flush. This config is the interval in millisecond time unit." |
public static final String |
TIER_PARTITION_STATE_METADATA_SNAPSHOTS_ENABLED |
"tier-partition-state-metadata-snapshots-feature-flag" |
public static final String |
TIER_PARTITION_STATE_METADATA_SNAPSHOTS_ENABLED_DOC |
"should be set to true if tier metadata snapshots are enabled." |
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 |