Constant Field Values

Contents

• com.linkedin.*

com.linkedin.*

com.linkedin.alpini.base.misc.HeaderNames

Modifier and Type	Constant Field	Value
public static final String	CONTENT_LENGTH	"Content-Length"
public static final String	CONTENT_LOCATION	"Content-Location"
public static final String	CONTENT_TYPE	"Content-Type"
public static final String	PROVIDER_CLASS_NAME	"com.linkedin.alpini.base.misc.spi.HeaderNames"
public static final String	SERVER	"Server"

com.linkedin.alpini.base.misc.HeaderUtils

Modifier and Type	Constant Field	Value
public static final String	HTTP_DATE_FORMAT	"EEE, dd MMM yyyy HH:mm:ss zzz"
public static final String	HTTP_DATE_GMT_TIMEZONE	"GMT"

com.linkedin.alpini.base.misc.Http2TooManyStreamsException

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_MESSAGE	"Max concurrent requests limit reached for storage node connection"

com.linkedin.alpini.base.misc.Metrics

Modifier and Type	Constant Field	Value
public static final long	UNSET_VALUE	-1L

com.linkedin.alpini.router.impl.Router.Builder

Modifier and Type	Constant Field	Value
public static final long	HANDSHAKE_TIMEOUT_MILLIS	60000L
public static final long	MINIMUM_IDLE_TIMEOUT_MILLIS	1000L
public static final int	MINIMUM_MAX_CHUNK_SIZE	256
public static final long	MINIMUM_MAX_CONTENT_LENGTH	0L
public static final int	MINIMUM_MAX_HEADER_SIZE	256
public static final int	MINIMUM_MAX_INITIAL_LINE_LENGTH	256

com.linkedin.davinci.blobtransfer.BlobSnapshotManager

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_SNAPSHOT_CLEANUP_INTERVAL_IN_MINS	120

com.linkedin.davinci.blobtransfer.BlobTransferUtils

Modifier and Type	Constant Field	Value
public static final String	BLOB_TRANSFER_COMPLETED	"Completed"
public static final String	BLOB_TRANSFER_STATUS	"X-Blob-Transfer-Status"
public static final String	BLOB_TRANSFER_TYPE	"X-Blob-Transfer-Type"

com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_CHUNK_SPLIT_THRESHOLD	100

com.linkedin.davinci.client.DaVinciRecordTransformerRecordMetadata

Modifier and Type	Constant Field	Value
public static final int	SENTINEL_WRITER_SCHEMA_ID	-1

com.linkedin.davinci.compression.UrnDictV1

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_DICT_SIZE	1024
public static final int	UNKNOWN_URN_TYPE_ID	-1
public static final String	URN_PREFIX	"urn:li:"

com.linkedin.davinci.config.StoreBackendConfig

Modifier and Type	Constant Field	Value
public static final String	CONFIG_DIRECTORY	"config"
public static final String	IS_MANAGED	"managed"

com.linkedin.davinci.config.VeniceConfigLoader

Modifier and Type	Constant Field	Value
public static final String	CLUSTER_PROPERTIES_FILE	"cluster.properties"
public static final String	KAFKA_CLUSTER_MAP_FILE	"kafka.cluster.map"
public static final String	SERVER_PROPERTIES_FILE	"server.properties"
public static final String	VENICE_CONFIG_DIR	"VENICE_CONFIG_DIR"

com.linkedin.davinci.config.VeniceServerConfig

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_CONSUMER_NUM_IN_CONSUMER_POOL_PER_KAFKA_CLUSTER	3

com.linkedin.davinci.consumer.VeniceChangeCoordinate

Modifier and Type	Constant Field	Value
public static final long	UNDEFINED_CONSUMER_SEQUENCE_ID	-1L

com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils

Modifier and Type	Constant Field	Value
public static final String	FORKED_PROCESS_METADATA_FILENAME	"ForkedProcessMetadata.conf"
public static final String	INGESTION_ISOLATION_CONFIG_PREFIX	"isolated"
public static final String	ISOLATED_INGESTION_CONFIG_FILENAME	"IsolatedIngestionConfig.conf"
public static final String	ISOLATED_INGESTION_KAFKA_CLUSTER_MAP_FILENAME	"IsolatedIngestionKafkaClusterMap.conf"
public static final String	PID	"pid"

com.linkedin.davinci.kafka.consumer.AdaptiveThrottlerSignalService

Modifier and Type	Constant Field	Value
public static final String	MULTI_GET_LATENCY_P99_METRIC_NAME	".total--multiget_storage_engine_query_latency.99thPercentile"
public static final String	READ_COMPUTE_LATENCY_P99_METRIC_NAME	".total--compute_storage_engine_query_latency.99thPercentile"
public static final String	SINGLE_GET_LATENCY_P99_METRIC_NAME	".total--success_request_latency.99thPercentile"

com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask

Modifier and Type	Constant Field	Value
public static final String	GLOBAL_RT_DIV_KEY_PREFIX	"GLOBAL_RT_DIV_KEY."

com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS	1800

com.linkedin.davinci.kafka.consumer.StoreIngestionTask

Modifier and Type	Constant Field	Value
protected static final long	KILL_WAIT_TIME_MS	5000L

com.linkedin.davinci.stats.BlobTransferStats

Modifier and Type	Constant Field	Value
protected static final String	BLOB_TRANSFER_FAILED_NUM_RESPONSES	"blob_transfer_failed_num_responses"
protected static final String	BLOB_TRANSFER_SUCCESSFUL_NUM_RESPONSES	"blob_transfer_successful_num_responses"
protected static final String	BLOB_TRANSFER_THROUGHPUT	"blob_transfer_file_receive_throughput"
protected static final String	BLOB_TRANSFER_TIME	"blob_transfer_time"
protected static final String	BLOB_TRANSFER_TOTAL_NUM_RESPONSES	"blob_transfer_total_num_responses"

com.linkedin.davinci.stats.DaVinciRecordTransformerStats

Modifier and Type	Constant Field	Value
public static final String	RECORD_TRANSFORMER_DELETE_ERROR_COUNT	"record_transformer_delete_error_count"
public static final String	RECORD_TRANSFORMER_DELETE_LATENCY	"record_transformer_delete_latency"
public static final String	RECORD_TRANSFORMER_PUT_ERROR_COUNT	"record_transformer_put_error_count"
public static final String	RECORD_TRANSFORMER_PUT_LATENCY	"record_transformer_put_latency"

com.linkedin.davinci.stats.HostLevelIngestionStats

Modifier and Type	Constant Field	Value
public static final String	ASSEMBLED_RECORD_SIZE_IN_BYTES	"assembled_record_size_in_bytes"
public static final String	ASSEMBLED_RECORD_SIZE_RATIO	"assembled_record_size_ratio"
public static final String	ASSEMBLED_RMD_SIZE_IN_BYTES	"assembled_rmd_size_in_bytes"

com.linkedin.davinci.stats.IngestionStats

Modifier and Type	Constant Field	Value
public static final String	BATCH_PROCESSING_REQUEST	"batch_processing_request"
public static final String	BATCH_PROCESSING_REQUEST_ERROR	"batch_processing_request_error"
public static final String	BATCH_PROCESSING_REQUEST_LATENCY	"batch_processing_request_latency"
public static final String	BATCH_PROCESSING_REQUEST_RECORDS	"batch_processing_request_records"
public static final String	BATCH_PROCESSING_REQUEST_SIZE	"batch_processing_request_size"
protected static final String	BYTES_CONSUMED_METRIC_NAME	"bytes_consumed"
protected static final String	CONSUMED_RECORD_END_TO_END_PROCESSING_LATENCY	"consumed_record_end_to_end_processing_latency"
protected static final String	FOLLOWER_BYTES_CONSUMED_METRIC_NAME	"follower_bytes_consumed"
protected static final String	FOLLOWER_RECORDS_CONSUMED_METRIC_NAME	"follower_records_consumed"
public static final String	IDLE_TIME	"idle_time"
protected static final String	INGESTION_TASK_ERROR_GAUGE	"ingestion_task_errored_gauge"
protected static final String	INGESTION_TASK_PUSH_TIMEOUT_GAUGE	"ingestion_task_push_timeout_gauge"
public static final String	INTERNAL_PREPROCESSING_LATENCY	"internal_preprocessing_latency"
protected static final String	LEADER_BYTES_CONSUMED_METRIC_NAME	"leader_bytes_consumed"
protected static final String	LEADER_BYTES_PRODUCED_METRIC_NAME	"leader_bytes_produced"
public static final String	LEADER_PREPROCESSING_LATENCY	"leader_preprocessing_latency"
protected static final String	LEADER_RECORDS_CONSUMED_METRIC_NAME	"leader_records_consumed"
protected static final String	LEADER_RECORDS_PRODUCED_METRIC_NAME	"leader_records_produced"
public static final String	NEARLINE_LOCAL_BROKER_TO_READY_TO_SERVE_LATENCY	"nearline_local_broker_to_ready_to_serve_latency"
public static final String	NEARLINE_PRODUCER_TO_LOCAL_BROKER_LATENCY	"nearline_producer_to_local_broker_latency"
protected static final String	OFFSET_REGRESSION_DCR_ERROR	"offset_regression_dcr_error"
public static final String	PRODUCER_CALLBACK_LATENCY	"producer_callback_latency"
protected static final String	RECORDS_CONSUMED_METRIC_NAME	"records_consumed"
public static final String	STORAGE_QUOTA_USED	"storage_quota_used"
protected static final String	SUBSCRIBE_ACTION_PREP_LATENCY	"subscribe_action_prep_latency"
protected static final String	TIMESTAMP_REGRESSION_DCR_ERROR	"timestamp_regression_dcr_error"
protected static final String	TOMBSTONE_CREATION_DCR	"tombstone_creation_dcr"
protected static final String	TOTAL_DCR	"total_dcr"
protected static final String	TOTAL_DUPLICATE_KEY_UPDATE_COUNT	"total_duplicate_key_update_count"
protected static final String	UPDATE_IGNORED_DCR	"update_ignored_dcr"
protected static final String	WRITE_COMPUTE_OPERATION_FAILURE	"write_compute_operation_failure"

com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_LAG_LOGGING_THREAD_SLEEP_INTERVAL_SECONDS	60
public static final int	DEFAULT_REPORTER_THREAD_SLEEP_INTERVAL_SECONDS	60
public static final long	INVALID_HEARTBEAT_LAG	9223372036854775807L
public static final long	INVALID_MESSAGE_TIMESTAMP	-1L

com.linkedin.davinci.storage.chunking.AbstractAvroChunkingAdapter<T>

Modifier and Type	Constant Field	Value
public static final int	DO_NOT_USE_READER_SCHEMA_ID	-1

com.linkedin.davinci.store.AbstractStorageEngine<Partition extends AbstractStoragePartition>

Modifier and Type	Constant Field	Value
public static final int	METADATA_PARTITION_ID	1000000000

com.linkedin.davinci.store.record.ValueRecord

Modifier and Type	Constant Field	Value
public static final int	SCHEMA_HEADER_LENGTH	4

com.linkedin.davinci.store.rocksdb.RocksDBServerConfig

Modifier and Type	Constant Field	Value
public static final String	CAPPED_PREFIX_EXTRACTOR_LENGTH	"rocksdb.capped.prefix.extractor.length"
public static final String	RECORD_TRANSFORMER_VALUE_SCHEMA	"record.transformer.value.schema"
public static final String	ROCKSDB_ATOMIC_FLUSH_ENABLED	"rocksdb.atomic.flush.enabled"
public static final String	ROCKSDB_AUTO_TUNED_RATE_LIMITER_ENABLED	"rocksdb.auto.tuned.rate.limited.enabled"
public static final String	ROCKSDB_BLOB_FILE_SIZE_IN_BYTES	"rocksdb.blob.file.size.in.bytes"
public static final String	ROCKSDB_BLOB_FILE_STARTING_LEVEL	"rocksdb.blob.file.starting.level"
public static final String	ROCKSDB_BLOB_FILES_ENABLED	"rocksdb.blob.files.enabled"
public static final String	ROCKSDB_BLOB_GARBAGE_COLLECTION_AGE_CUTOFF	"rocksdb.blob.garbage.collection.age.cutoff"
public static final String	ROCKSDB_BLOB_GARBAGE_COLLECTION_FORCE_THRESHOLD	"rocksdb.blob.garbage.collection.force.threshold"
public static final String	ROCKSDB_BLOCK_BASE_FORMAT_VERSION	"rocksdb.block.base.format.version"
public static final String	ROCKSDB_BLOCK_CACHE_COMPRESSED_SIZE_IN_BYTES	"rocksdb.block.cache.compressed.size.in.bytes"
public static final String	ROCKSDB_BLOCK_CACHE_IMPLEMENTATION	"rocksdb.block.cache.implementation"
public static final String	ROCKSDB_BLOCK_CACHE_MEMORY_LIMIT	"rocksdb.block.cache.memory.limit"
public static final String	ROCKSDB_BLOCK_CACHE_SHARD_BITS	"rocksdb.block.cache.shard.bits"
public static final String	ROCKSDB_BLOCK_CACHE_SIZE_IN_BYTES	"rocksdb.block.cache.size.in.bytes"
public static final String	ROCKSDB_BLOCK_CACHE_STRICT_CAPACITY_LIMIT	"rocksdb.block.cache.strict.capacity.limit"
public static final String	ROCKSDB_BLOOM_BITS_PER_KEY	"rocksdb.bloom.bits.per.key"
public static final String	ROCKSDB_BYTES_PER_SYNC	"rocksdb.bytes.per.sync"
public static final String	ROCKSDB_DB_OPEN_OPERATION_THROTTLE	"rocksdb.db.open.operation.throttle"
public static final String	ROCKSDB_ENV_COMPACTION_POOL_SIZE	"rocksdb.env.compaction.pool.size"
public static final String	ROCKSDB_ENV_FLUSH_POOL_SIZE	"rocksdb.env.flush.pool.size"
public static final String	ROCKSDB_HASH_TABLE_RATIO	"rocksdb.hash.table.ratio"
public static final String	ROCKSDB_HUGE_PAGE_TLB_SIZE	"rocksdb.huge.page.tlb.size"
public static final String	ROCKSDB_ITERATOR_READ_AHEAD_SIZE_IN_BYTES	"rocksdb.iterator.read.ahead.size.in.bytes"
public static final String	ROCKSDB_LEVEL0_COMPACTION_TUNING_FOR_READ_WRITE_LEADER_ENABLED	"rocksdb.level0.compaction.tuning.for.read.write.leader.enabled"
public static final String	ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER	"rocksdb.level0.file.num.compaction.trigger"
public static final String	ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER_FOR_READ_WRITE_LEADER	"rocksdb.level0.file.num.compaction.trigger.for.read.write.leader"
public static final String	ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER_WRITE_ONLY_VERSION	"rocksdb.level0.file.num.compaction.trigger.write.only.version"
public static final String	ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER	"rocksdb.level0.slowdown.writes.trigger"
public static final String	ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER_FOR_READ_WRITE_LEADER	"rocksdb.level0.slowdown.writes.trigger.for.read.write.leader"
public static final String	ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER_WRITE_ONLY_VERSION	"rocksdb.level0.slowdown.writes.trigger.write.only.version"
public static final String	ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER	"rocksdb.level0.stops.writes.trigger"
public static final String	ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER_FOR_READ_WRITE_LEADER	"rocksdb.level0.stops.writes.trigger.for.read.write.leader"
public static final String	ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER_WRITE_ONLY_VERSION	"rocksdb.level0.stops.writes.trigger.write.only.version"
public static final String	ROCKSDB_MAX_BYTES_FOR_LEVEL_BASE	"rocksdb.max.bytes.for.level.base"
public static final String	ROCKSDB_MAX_FILE_OPENING_THREADS	"rocksdb.max.file.opening.threads"
public static final String	ROCKSDB_MAX_LOG_FILE_NUM	"rocksdb.max.log.file.num"
public static final String	ROCKSDB_MAX_LOG_FILE_SIZE	"rocksdb.max.log.file.size"
public static final String	ROCKSDB_MAX_MEMTABLE_COUNT	"rocksdb.max.memtable.count"
public static final String	ROCKSDB_MAX_OPEN_FILES	"rocksdb.max.open.files"
public static final String	ROCKSDB_MAX_TOTAL_WAL_SIZE_IN_BYTES	"rocksdb.max.total.wal.size.in.bytes"
public static final String	ROCKSDB_MEM_TABLE_HUGE_PAGE_SIZE_BYTES	"rocksdb.mem.table.huge.page.size.in.bytes"
public static final String	ROCKSDB_MEMTABLE_SIZE_IN_BYTES	"rocksdb.memtable.size.in.bytes"
public static final String	ROCKSDB_MIN_BLOB_SIZE_IN_BYTES	"rocksdb.min.blob.size.in.bytes"
public static final String	ROCKSDB_MIN_WRITE_BUFFER_NUMBER_TO_MERGE	"rocksdb.min.write.buffer.number.to.merge"
public static final String	ROCKSDB_OPTIONS_COMPACTION_STYLE	"rocksdb.options.compaction.style"
public static final String	ROCKSDB_OPTIONS_COMPRESSION_TYPE	"rocksdb.options.compression.type"
public static final String	ROCKSDB_OPTIONS_USE_DIRECT_READS	"rocksdb.options.use.direct.reads"
public static final String	ROCKSDB_PLAIN_TABLE_FORMAT_ENABLED	"rocksdb.plain.table.format.enabled"
public static final String	ROCKSDB_PUT_REUSE_BYTE_BUFFER	"rocksdb.put.reuse.byte.buffer"
public static final String	ROCKSDB_RMD_BLOCK_CACHE_SIZE_IN_BYTES	"rocksdb.rmd.block.cache.size.in.bytes"
public static final String	ROCKSDB_SEPARATE_RMD_CACHE_ENABLED	"rocksdb.separate.rmd.cache.enabled"
public static final String	ROCKSDB_SET_CACHE_INDEX_AND_FILTER_BLOCKS	"rocksdb.set.cache.index.and.filter.blocks"
public static final String	ROCKSDB_SST_FILE_BLOCK_SIZE_IN_BYTES	"rocksdb.sst.file.block.size.in.bytes"
public static final String	ROCKSDB_STATISTICS_ENABLED	"rocksdb.statistics.enabled"
public static final String	ROCKSDB_STORE_INDEX_IN_FILE	"rocksdb.store.index.in.file"
public static final String	ROCKSDB_TARGET_FILE_SIZE_IN_BYTES	"rocksdb.target.file.size.in.bytes"
public static final String	ROCKSDB_TOTAL_MEMTABLE_USAGE_CAP_IN_BYTES	"rocksdb.total.memtable.usage.cap.in.bytes"
public static final String	ROCKSDB_WRITE_QUOTA_BYTES_PER_SECOND	"rocksdb.write.quota.bytes.per.second"

com.linkedin.davinci.store.rocksdb.RocksDBSstFileWriter

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_COLUMN_FAMILY_INDEX	0
protected static final int	REPLICATION_METADATA_COLUMN_FAMILY_INDEX	1
protected static final String	ROCKSDB_LAST_FINISHED_RMD_SST_FILE_NO	"rocksdb_last_finished_rmd_sst_file_no"
protected static final String	ROCKSDB_LAST_FINISHED_SST_FILE_NO	"rocksdb_last_finished_sst_file_no"

com.linkedin.davinci.store.rocksdb.RocksDBStorageEngine

Modifier and Type	Constant Field	Value
public static final String	SERVER_CONFIG_FILE_NAME	"rocksdbConfig"

com.linkedin.davinci.store.rocksdb.RocksDBStoragePartition

Modifier and Type	Constant Field	Value
protected static final String	ROCKSDB_ERROR_MESSAGE_FOR_RUNNING_OUT_OF_DISK_QUOTA	"No space left on device"

com.linkedin.davinci.validation.DataIntegrityValidator

Modifier and Type	Constant Field	Value
public static final long	DISABLED	-1L

com.linkedin.davinci.validation.PartitionTracker.TopicType

Modifier and Type	Constant Field	Value
public static final int	REALTIME_TOPIC_TYPE	1
public static final int	VERSION_TOPIC_TYPE	0

com.linkedin.venice.BackfillMinIsrTask

Modifier and Type	Constant Field	Value
public static final String	TASK_NAME	"BackfillMinIsr"

com.linkedin.venice.CommonConfigKeys

Modifier and Type	Constant Field	Value
public static final String	SSL_ENABLED	"ssl.enabled"
public static final String	SSL_FACTORY_CLASS_NAME	"ssl.factory.class.name"
public static final String	SSL_KEY_PASSWORD	"ssl.key.password"
public static final String	SSL_KEYMANAGER_ALGORITHM	"ssl.keymanager.algorithm"
public static final String	SSL_KEYSTORE_LOCATION	"ssl.keystore.location"
public static final String	SSL_KEYSTORE_PASSWORD	"ssl.keystore.password"
public static final String	SSL_KEYSTORE_TYPE	"ssl.keystore.type"
public static final String	SSL_NEEDS_CLIENT_CERT	"ssl.needs.client.cert"
public static final String	SSL_SECURE_RANDOM_IMPLEMENTATION	"ssl.secure.random.implementation"
public static final String	SSL_TRUSTMANAGER_ALGORITHM	"ssl.trustmanager.algorithm"
public static final String	SSL_TRUSTSTORE_LOCATION	"ssl.truststore.location"
public static final String	SSL_TRUSTSTORE_PASSWORD	"ssl.truststore.password"
public static final String	SSL_TRUSTSTORE_TYPE	"ssl.truststore.type"

com.linkedin.venice.ConfigConstants

Modifier and Type	Constant Field	Value
public static final String	CONTROLLER_DEFAULT_HELIX_RESOURCE_CAPACITY_KEY	"cluster_resource_weight"
public static final int	DEFAULT_MAX_RECORD_SIZE_BYTES_BACKFILL	104857600
public static final int	UNSPECIFIED_REPLICATION_METADATA_VERSION	-1

com.linkedin.venice.ConfigKeys

Modifier and Type	Constant Field	Value
public static final String	ACL_IN_MEMORY_CACHE_TTL_MS	"acl.in.memory.cache.ttl.ms"
public static final String	ACTIVE_ACTIVE_REAL_TIME_SOURCE_FABRIC_LIST	"active.active.real.time.source.fabric.list"
public static final String	ADMIN_CHECK_READ_METHOD_FOR_KAFKA	"admin.check.read.method.for.kafka"
public static final String	ADMIN_CONSUMPTION_CYCLE_TIMEOUT_MS	"admin.consumption.cycle.timeout.ms"
public static final String	ADMIN_CONSUMPTION_MAX_WORKER_THREAD_POOL_SIZE	"admin.consumption.max.worker.thread.pool.size"
public static final String	ADMIN_HELIX_MESSAGING_CHANNEL_ENABLED	"admin.helix.messaging.channel.enabled"
public static final String	ADMIN_HOSTNAME	"admin.hostname"
public static final String	ADMIN_PORT	"admin.port"
public static final String	ADMIN_SECURE_PORT	"admin.secure.port"
public static final String	ADMIN_TOPIC_REPLICATION_FACTOR	"admin.topic.replication.factor"
public static final String	ADMIN_TOPIC_SOURCE_REGION	"admin.topic.source.region"
public static final String	AGGREGATE_REAL_TIME_SOURCE_REGION	"aggregate.real.time.source.region"
public static final String	ALLOW_CLUSTER_WIPE	"allow.cluster.wipe"
public static final String	ALLOW_STORE_MIGRATION	"allow.store.migration"
public static final String	AUTOCREATE_DATA_PATH	"autocreate.data.path"
public static final String	BLOB_RECEIVE_MAX_TIMEOUT_IN_MIN	"blob.receive.max.timeout.in.min"
public static final String	BLOB_RECEIVE_READER_IDLE_TIME_IN_SECONDS	"blob.receive.reader.idle.time.in.seconds"
public static final String	BLOB_TRANSFER_ACL_ENABLED	"blob.transfer.acl.enabled"
public static final String	BLOB_TRANSFER_CLIENT_READ_LIMIT_BYTES_PER_SEC	"blob.transfer.client.read.limit.bytes.per.sec"
public static final String	BLOB_TRANSFER_DISABLED_OFFSET_LAG_THRESHOLD	"blob.transfer.disabled.offset.lag.threshold"
public static final String	BLOB_TRANSFER_MANAGER_ENABLED	"blob.transfer.manager.enabled"
public static final String	BLOB_TRANSFER_MAX_CONCURRENT_SNAPSHOT_USER	"blob.transfer.max.concurrent.snapshot.user"
public static final String	BLOB_TRANSFER_MAX_TIMEOUT_IN_MIN	"blob.transfer.max.timeout.in.min"
public static final String	BLOB_TRANSFER_PEERS_CONNECTIVITY_FRESHNESS_IN_SECONDS	"blob.transfer.peers.connectivity.freshness.in.seconds"
public static final String	BLOB_TRANSFER_RECEIVER_SERVER_POLICY	"blob.transfer.receiver.server.policy"
public static final String	BLOB_TRANSFER_SERVICE_WRITE_LIMIT_BYTES_PER_SEC	"blob.transfer.service.write.limit.bytes.per.sec"
public static final String	BLOB_TRANSFER_SNAPSHOT_CLEANUP_INTERVAL_IN_MINS	"blob.transfer.snapshot.cleanup.interval.in.mins"
public static final String	BLOB_TRANSFER_SNAPSHOT_RETENTION_TIME_IN_MIN	"blob.transfer.snapshot.retention.time.in.min"
public static final String	BLOB_TRANSFER_SSL_ENABLED	"blob.transfer.ssl.enabled"
public static final String	CHILD_CLUSTER_ALLOWLIST	"child.cluster.allowlist"
public static final String	CHILD_CLUSTER_D2_PREFIX	"child.cluster.d2.zkHost."
public static final String	CHILD_CLUSTER_D2_SERVICE_NAME	"child.cluster.d2.service.name"
public static final String	CHILD_CLUSTER_URL_PREFIX	"child.cluster.url."
public static final String	CHILD_CLUSTER_WHITELIST	"child.cluster.whitelist"
public static final String	CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED	"child.controller.admin.topic.consumption.enabled"
public static final String	CHILD_DATA_CENTER_KAFKA_URL_PREFIX	"child.data.center.kafka.url"
public static final String	CLIENT_PRODUCER_SCHEMA_REFRESH_INTERVAL_SECONDS	"client.producer.schema.refresh.interval.seconds"
public static final String	CLIENT_PRODUCER_THREAD_NUM	"client.producer.thread.num"
public static final String	CLIENT_SYSTEM_STORE_REPOSITORY_REFRESH_INTERVAL_SECONDS	"client.system.store.repository.refresh.interval.seconds"
public static final String	CLIENT_USE_REQUEST_BASED_METADATA_REPOSITORY	"client.use.request.based.metadata.repository"
public static final String	CLIENT_USE_SYSTEM_STORE_REPOSITORY	"client.use.system.store.repository"
public static final String	CLUSTER_DISCOVERY_D2_SERVICE	"cluster.discovery.d2.service"
public static final String	CLUSTER_NAME	"cluster.name"
public static final String	CLUSTER_TO_D2	"cluster.to.d2"
public static final String	CLUSTER_TO_SERVER_D2	"cluster.to.server.d2"
public static final String	CONCURRENT_INIT_ROUTINES_ENABLED	"concurrent.init.routines.enabled"
public static final String	CONCURRENT_PUSH_DETECTION_STRATEGY	"concurrent.push.detection.strategy"
public static final String	CONTROLLER_ADD_VERSION_VIA_ADMIN_PROTOCOL	"controller.add.version.via.admin.protocol"
public static final String	CONTROLLER_ADMIN_GRPC_PORT	"controller.admin.grpc.port"
public static final String	CONTROLLER_ADMIN_SECURE_GRPC_PORT	"controller.admin.secure.grpc.port"
public static final String	CONTROLLER_AUTO_MATERIALIZE_DAVINCI_PUSH_STATUS_SYSTEM_STORE	"controller.auto.materialize.davinci.push.status.system.store"
public static final String	CONTROLLER_AUTO_MATERIALIZE_META_SYSTEM_STORE	"controller.auto.materialize.meta.system.store"
public static final String	CONTROLLER_BACKUP_VERSION_DEFAULT_RETENTION_MS	"controller.backup.version.default.retention.ms"
public static final String	CONTROLLER_BACKUP_VERSION_DELETION_SLEEP_MS	"controller.backup.version.deletion.sleep.ms"
public static final String	CONTROLLER_BACKUP_VERSION_METADATA_FETCH_BASED_CLEANUP_ENABLED	"controller.backup.version.metadata.fetch.cleanup.enabled"
public static final String	CONTROLLER_BACKUP_VERSION_REPLICA_REDUCTION_ENABLED	"controller.backup.version.replica.reduction.enabled"
public static final String	CONTROLLER_BACKUP_VERSION_RETENTION_BASED_CLEANUP_ENABLED	"controller.backup.version.retention.based.cleanup.enabled"
public static final String	CONTROLLER_CLUSTER	"controller.cluster.name"
public static final String	CONTROLLER_CLUSTER_HELIX_CLOUD_ENABLED	"controller.cluster.helix.cloud.enabled"
public static final String	CONTROLLER_CLUSTER_LEADER_HAAS	"controller.cluster.leader.haas.enabled"
public static final String	CONTROLLER_CLUSTER_REPLICA	"controller.cluster.replica"
public static final String	CONTROLLER_CLUSTER_ZK_ADDRESSS	"controller.cluster.zk.address"
public static final String	CONTROLLER_DANGLING_TOPIC_CLEAN_UP_INTERVAL_SECOND	"controller.dangling.topic.clean.up.interval.second"
public static final String	CONTROLLER_DANGLING_TOPIC_OCCURRENCE_THRESHOLD_FOR_CLEANUP	"controller.dangling.topic.occurrence.threshold.for.cleanup"
public static final String	CONTROLLER_DEAD_STORE_ENDPOINT_ENABLED	"controller.dead.store.endpoint.enabled"
public static final String	CONTROLLER_DEAD_STORE_STATS_CLASS_NAME	"controller.dead.store.stats.class.name"
public static final String	CONTROLLER_DEAD_STORE_STATS_PRE_FETCH_ENABLED	"controller.dead.store.stats.pre.fetch.enabled"
public static final String	CONTROLLER_DEAD_STORE_STATS_PRE_FETCH_INTERVAL_MS	"controller.dead.store.stats.pre.fetch.interval.ms"
public static final String	CONTROLLER_DEAD_STORE_STATS_PREFIX	"controller.dead.store.stats."
public static final String	CONTROLLER_DEFAULT_READ_QUOTA_PER_ROUTER	"controller.default.read.quota.per.router"
public static final String	CONTROLLER_DEFERRED_VERSION_SWAP_SERVICE_ENABLED	"controller.deferred.version.swap.service.enabled"
public static final String	CONTROLLER_DEFERRED_VERSION_SWAP_SLEEP_MS	"controller.deferred.version.swap.sleep.ms"
public static final String	CONTROLLER_DISABLE_PARENT_REQUEST_TOPIC_FOR_STREAM_PUSHES	"controller.disable.parent.request.topic.for.stream.pushes"
public static final String	CONTROLLER_DISABLE_PARENT_TOPIC_TRUNCATION_UPON_COMPLETION	"controller.disable.parent.topic.truncation.upon.completion"
public static final String	CONTROLLER_DISABLED_REPLICA_ENABLER_INTERVAL_MS	"controller.disabled.replica.enabler.interval.ms"
public static final String	CONTROLLER_DISABLED_ROUTES	"controller.cluster.disabled.routes"
public static final String	CONTROLLER_EARLY_DELETE_BACKUP_ENABLED	"controller.early.delete.backup.enabled"
public static final String	CONTROLLER_ENABLE_DISABLED_REPLICA_ENABLED	"controller.enable.disabled.replica.enabled"
public static final String	CONTROLLER_ENABLE_HYBRID_STORE_PARTITION_COUNT_UPDATE	"controller.enable.hybrid.store.partition.count.update"
public static final String	CONTROLLER_ENABLE_REAL_TIME_TOPIC_VERSIONING	"controller.enable.realtime.topic.versioning"
public static final String	CONTROLLER_ENABLE_STREAM_PUSH_SOURCE_GRID_FABRIC_OVERRIDE	"controller.enable.stream.push.source.grid.fabric.override"
public static final String	CONTROLLER_ENFORCE_SSL	"controller.enforce.ssl"
public static final String	CONTROLLER_GRPC_SERVER_ENABLED	"controller.grpc.server.enabled"
public static final String	CONTROLLER_GRPC_SERVER_THREAD_COUNT	"controller.grpc.server.thread.count"
public static final String	CONTROLLER_HAAS_SUPER_CLUSTER_NAME	"controller.haas.super.cluster.name"
public static final String	CONTROLLER_HELIX_CLOUD_ID	"controller.helix.cloud.id"
public static final String	CONTROLLER_HELIX_CLOUD_INFO_PROCESSOR_NAME	"controller.helix.cloud.info.processor.name"
public static final String	CONTROLLER_HELIX_CLOUD_INFO_PROCESSOR_PACKAGE	"controller.helix.cloud.info.processor.package"
public static final String	CONTROLLER_HELIX_CLOUD_INFO_SOURCES	"controller.helix.cloud.info.sources"
public static final String	CONTROLLER_HELIX_CLOUD_PROVIDER	"controller.helix.cloud.provider"
public static final String	CONTROLLER_HELIX_INSTANCE_CAPACITY	"controller.helix.instance.capacity"
public static final String	CONTROLLER_HELIX_PARTICIPANT_DEREGISTRATION_TIMEOUT_MS	"controller.helix.participant.deregistration.timeout.ms"
public static final String	CONTROLLER_HELIX_REBALANCE_PREFERENCE_EVENNESS	"controller.helix.rebalance.preference.evenness"
public static final String	CONTROLLER_HELIX_REBALANCE_PREFERENCE_FORCE_BASELINE_CONVERGE	"controller.helix.rebalance.preference.force.baseline.converge"
public static final String	CONTROLLER_HELIX_REBALANCE_PREFERENCE_LESS_MOVEMENT	"controller.helix.rebalance.preference.less.movement"
public static final String	CONTROLLER_HELIX_RESOURCE_CAPACITY_WEIGHT	"controller.helix.default.instance.capacity"
public static final String	CONTROLLER_HELIX_REST_CUSTOMIZED_HEALTH_URL	"controller.helix.rest.customized.health.url"
public static final String	CONTROLLER_HELIX_SERVER_CLUSTER_FAULT_ZONE_TYPE	"controller.helix.server.cluster.fault.zone.type"
public static final String	CONTROLLER_HELIX_SERVER_CLUSTER_TOPOLOGY	"controller.helix.server.cluster.topology"
public static final String	CONTROLLER_HELIX_SERVER_CLUSTER_TOPOLOGY_AWARE	"controller.helix.server.cluster.topology.aware"
public static final String	CONTROLLER_INSTANCE_TAG_LIST	"controller.instance.tag.list"
public static final String	CONTROLLER_JETTY_CONFIG_OVERRIDE_PREFIX	"controller.jetty."
public static final String	CONTROLLER_MIN_SCHEMA_COUNT_TO_KEEP	"controller.min.schema.count.keep"
public static final String	CONTROLLER_NAME	"controller.name"
public static final String	CONTROLLER_PARENT_EXTERNAL_SUPERSET_SCHEMA_GENERATION_ENABLED	"controller.parent.external.superset.schema.generation.enabled"
public static final String	CONTROLLER_PARENT_MODE	"controller.parent.mode"
public static final String	CONTROLLER_PARENT_REGION_STATE	"controller.parent.region.state"
public static final String	CONTROLLER_PARENT_SYSTEM_STORE_HEARTBEAT_CHECK_WAIT_TIME_SECONDS	"controller.parent.system.store.heartbeat.check.wait.time.seconds"
public static final String	CONTROLLER_PARENT_SYSTEM_STORE_REPAIR_CHECK_INTERVAL_SECONDS	"controller.parent.system.store.repair.check.interval.seconds"
public static final String	CONTROLLER_PARENT_SYSTEM_STORE_REPAIR_SERVICE_ENABLED	"controller.parent.system.store.repair.service.enabled"
public static final String	CONTROLLER_PARENT_SYSTEM_STORE_VERSION_REFRESH_THRESHOLD_IN_DAYS	"controller.parent.system.store.version.refresh.threshold.in.days"
public static final String	CONTROLLER_PROTOCOL_VERSION_AUTO_DETECTION_SERVICE_ENABLED	"controller.protocol.version.auto.detection.service.enabled"
public static final String	CONTROLLER_PROTOCOL_VERSION_AUTO_DETECTION_SLEEP_MS	"controller.protocol.version.auto.detection.sleep.ms"
public static final String	CONTROLLER_REPUSH_PREFIX	"controller.repush."
public static final String	CONTROLLER_RESOURCE_INSTANCE_GROUP_TAG	"controller.resource.instance.group.tag"
public static final String	CONTROLLER_SCHEMA_VALIDATION_ENABLED	"controller.schema.validation.enabled"
public static final String	CONTROLLER_SSL_ENABLED	"controller.ssl.enabled"
public static final String	CONTROLLER_STORAGE_CLUSTER_HELIX_CLOUD_ENABLED	"controller.storage.cluster.helix.cloud.enabled"
public static final String	CONTROLLER_STORE_GRAVEYARD_CLEANUP_DELAY_MINUTES	"controller.store.graveyard.cleanup.delay.minutes"
public static final String	CONTROLLER_STORE_GRAVEYARD_CLEANUP_ENABLED	"controller.store.graveyard.cleanup.enabled"
public static final String	CONTROLLER_STORE_GRAVEYARD_CLEANUP_SLEEP_INTERVAL_BETWEEN_LIST_FETCH_MINUTES	"controller.store.graveyard.cleanup.sleep.interval.between.list.fetch.minutes"
public static final String	CONTROLLER_STORE_RECREATION_AFTER_DELETION_TIME_WINDOW_SECONDS	"controller.store.recreation.after.deletion.time.window.seconds"
public static final String	CONTROLLER_SYSTEM_SCHEMA_CLUSTER_NAME	"controller.system.schema.cluster.name"
public static final String	CONTROLLER_SYSTEM_STORE_ACL_SYNCHRONIZATION_DELAY_MS	"controller.system.store.acl.synchronization.delay.ms"
public static final String	CONTROLLER_UNUSED_SCHEMA_CLEANUP_INTERVAL_SECONDS	"controller.unused.schema.cleanup.interval.seconds"
public static final String	CONTROLLER_UNUSED_VALUE_SCHEMA_CLEANUP_ENABLED	"controller.unused.value.schema.cleanup.enabled"
public static final String	CONTROLLER_USE_MULTI_REGION_REAL_TIME_TOPIC_SWITCHER_ENABLED	"controller.use.multi.region.real.time.topic.switcher.enabled"
public static final String	CONTROLLER_ZK_SHARED_DAVINCI_PUSH_STATUS_SYSTEM_SCHEMA_STORE_AUTO_CREATION_ENABLED	"controller.zk.shared.davinci.push.status.system.schema.store.auto.creation.enabled"
public static final String	CONTROLLER_ZK_SHARED_META_SYSTEM_SCHEMA_STORE_AUTO_CREATION_ENABLED	"controller.zk.shared.metadata.system.schema.store.auto.creation.enabled"
public static final String	D2_ZK_HOSTS_ADDRESS	"r2d2Client.zkHosts"
public static final String	DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_QUOTA_BYTES_PER_SECOND	"da.vinci.current.version.bootstrapping.quota.bytes.per.second"
public static final String	DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_QUOTA_RECORDS_PER_SECOND	"da.vinci.current.version.bootstrapping.quota.records.per.second"
public static final String	DA_VINCI_CURRENT_VERSION_BOOTSTRAPPING_SPEEDUP_ENABLED	"da.vinci.current.version.bootstrapping.speedup.enabled"
public static final String	DATA_BASE_PATH	"data.base.path"
public static final String	DAVINCI_P2P_BLOB_TRANSFER_CLIENT_PORT	"davinci.p2p.blob.transfer.client.port"
public static final String	DAVINCI_P2P_BLOB_TRANSFER_SERVER_PORT	"davinci.p2p.blob.transfer.server.port"
public static final String	DAVINCI_PUSH_STATUS_CHECK_INTERVAL_IN_MS	"davinci.push.status.check.interval.in.ms"
public static final String	DAVINCI_PUSH_STATUS_SCAN_ENABLED	"davinci.push.status.scan.enabled"
public static final String	DAVINCI_PUSH_STATUS_SCAN_INTERVAL_IN_SECONDS	"davinci.push.status.scan.interval.in.seconds"
public static final String	DAVINCI_PUSH_STATUS_SCAN_MAX_OFFLINE_INSTANCE_COUNT	"davinci.push.status.scan.max.offline.instance.count"
public static final String	DAVINCI_PUSH_STATUS_SCAN_MAX_OFFLINE_INSTANCE_RATIO	"davinci.push.status.scan.max.offline.instance.ratio"
public static final String	DAVINCI_PUSH_STATUS_SCAN_NO_REPORT_RETRY_MAX_ATTEMPTS	"davinci.push.status.scan.no.report.retry.max.attempts"
public static final String	DAVINCI_PUSH_STATUS_SCAN_THREAD_NUMBER	"davinci.push.status.scan.thread.number"
public static final String	DAVINCI_RECORD_TRANSFORMER_ON_RECOVERY_THREAD_POOL_SIZE	"davinci.record.transformer.on.recovery.thread.pool.size"
public static final String	DAVINCI_VALIDATE_SPECIFIC_SCHEMA_ENABLED	"davinci.validate.specific.schema.enabled"
public static final boolean	DEFAULT_CONTROLLER_ENABLE_REAL_TIME_TOPIC_VERSIONING	false
public static final String	DEFAULT_MAX_NUMBER_OF_PARTITIONS	"default.partition.max.count"
public static final String	DEFAULT_MAX_RECORD_SIZE_BYTES	"default.max.record.size.bytes"
public static final String	DEFAULT_NUMBER_OF_PARTITION	"default.partition.count"
public static final String	DEFAULT_NUMBER_OF_PARTITION_FOR_HYBRID	"default.partition.count.for.hybrid"
public static final String	DEFAULT_OFFLINE_PUSH_STRATEGY	"default.offline.push.strategy"
public static final String	DEFAULT_PARTITION_SIZE	"default.partition.size"
public static final String	DEFAULT_READ_STRATEGY	"default.read.strategy"
public static final String	DEFAULT_REPLICA_FACTOR	"default.replica.factor"
public static final String	DEFAULT_ROUTING_STRATEGY	"default.routing.strategy"
public static final String	DEFERRED_VERSION_SWAP_BUFFER_TIME	"deferred.version.swap.buffer.time"
public static final String	DEFERRED_VERSION_SWAP_REGION_ROLL_FORWARD_ORDER	"deferred.version.swap.region.roll.forward.order"
public static final String	DEFERRED_VERSION_SWAP_THREAD_POOL_SIZE	"deferred.version.swap.thread.pool.size"
public static final String	DELAY_TO_REBALANCE_MS	"delay.to.rebalance.ms"
public static final String	DEPRECATED_TOPIC_MAX_RETENTION_MS	"deprecated.topic.max.retention.ms"
public static final String	DEPRECATED_TOPIC_RETENTION_MS	"deprecated.topic.retention.ms"
public static final String	DIV_PRODUCER_STATE_MAX_AGE_MS	"div.producer.state.max.age.ms"
public static final String	EMERGENCY_SOURCE_REGION	"emergency.source.region"
public static final String	ENABLE_ACTIVE_ACTIVE_REPLICATION_AS_DEFAULT_FOR_HYBRID_STORE	"enable.active.active.replication.as.default.for.hybrid.store"
public static final String	ENABLE_BLOB_TRANSFER	"enable.blob.transfer"
public static final String	ENABLE_GRPC_READ_SERVER	"grpc.read.server.enabled"
public static final String	ENABLE_HYBRID_PUSH_SSL_ALLOWLIST	"enable.hybrid.push.ssl.allowlist"
public static final String	ENABLE_HYBRID_PUSH_SSL_WHITELIST	"enable.hybrid.push.ssl.whitelist"
public static final String	ENABLE_INCREMENTAL_PUSH_FOR_HYBRID_ACTIVE_ACTIVE_USER_STORES	"enable.incremental.push.for.hybrid.active.active.user.stores"
public static final String	ENABLE_OFFLINE_PUSH_SSL_ALLOWLIST	"enable.offline.push.ssl.allowlist"
public static final String	ENABLE_OFFLINE_PUSH_SSL_WHITELIST	"enable.offline.push.ssl.whitelist"
public static final String	ENABLE_PARTIAL_UPDATE_FOR_HYBRID_ACTIVE_ACTIVE_USER_STORES	"enable.partial.update.for.hybrid.active.active.user.stores"
public static final String	ENABLE_PARTIAL_UPDATE_FOR_HYBRID_NON_ACTIVE_ACTIVE_USER_STORES	"enable.partial.update.for.hybrid.non.active.active.user.stores"
public static final String	ENABLE_PARTITION_COUNT_ROUND_UP	"enable.partition.count.round.up"
public static final String	ENABLE_SEPARATE_REAL_TIME_TOPIC_FOR_STORE_WITH_INCREMENTAL_PUSH	"enable.separate.real.time.topic.for.store.with.incremental.push"
public static final String	ENABLE_SERVER_ALLOW_LIST	"enable.server.allowlist"
public static final String	ENFORCE_SECURE_ROUTER	"router.enforce.ssl"
public static final String	ERROR_PARTITION_AUTO_RESET_LIMIT	"error.partition.auto.reset.limit"
public static final String	ERROR_PARTITION_PROCESSING_CYCLE_DELAY	"error.partition.processing.cycle.delay"
public static final String	FAST_AVRO_FIELD_LIMIT_PER_METHOD	"fast.avro.field.limit.per.method"
public static final String	FATAL_DATA_VALIDATION_FAILURE_TOPIC_RETENTION_MS	"fatal.data.validation.failure.topic.retention.ms"
public static final String	FORCE_LEADER_ERROR_REPLICA_FAIL_OVER_ENABLED	"controller.force.leader.error.replica.fail.over.enabled"
public static final String	FREEZE_INGESTION_IF_READY_TO_SERVE_OR_LOCAL_DATA_EXISTS	"freeze.ingestion.if.ready.to.serve.or.local.data.exists"
public static final String	GLOBAL_RT_DIV_ENABLED	"global.rt.div.enabled"
public static final String	GRPC_READ_SERVER_PORT	"grpc.read.server.port"
public static final String	GRPC_SERVER_WORKER_THREAD_COUNT	"grpc.server.worker.thread.count"
public static final String	HEARTBEAT_CYCLE	"heartbeat.cycle"
public static final String	HEARTBEAT_TIMEOUT	"heartbeat.timeout"
public static final String	HELIX_HYBRID_STORE_QUOTA_ENABLED	"helix.hybrid.store.quota.enabled"
public static final String	HELIX_REBALANCE_ALG	"helix.rebalance.alg"
public static final String	HELIX_SEND_MESSAGE_TIMEOUT_MS	"helix.send.message.timeout.ms"
public static final String	HYBRID_QUOTA_ENFORCEMENT_ENABLED	"server.hybrid.quota.enforcement.enabled"
public static final String	IDENTITY_PARSER_CLASS	"identity.parser.class"
public static final String	INGESTION_USE_DA_VINCI_CLIENT	"ingestion.use.da.vinci.client"
public static final String	INSTANCE_ID	"instance.id"
public static final String	IS_DARK_CLUSTER	"is.dark.cluster"
public static final String	KAFKA_ADMIN_GET_TOPIC_CONFIG_MAX_RETRY_TIME_SEC	"kafka.admin.get.topic.config.max.retry.sec"
public static final String	KAFKA_BOOTSTRAP_SERVERS	"kafka.bootstrap.servers"
public static final String	KAFKA_CLIENT_ID_CONFIG	"kafka.client.id"
public static final String	KAFKA_CLUSTER_MAP_KEY_NAME	"name"
public static final String	KAFKA_CLUSTER_MAP_KEY_OTHER_URLS	"otherUrls"
public static final String	KAFKA_CLUSTER_MAP_KEY_URL	"url"
public static final String	KAFKA_CLUSTER_MAP_SECURITY_PROTOCOL	"securityProtocol"
public static final String	KAFKA_CONFIG_PREFIX	"kafka."
public static final String	KAFKA_EMPTY_POLL_SLEEP_MS	"kafka.empty.poll.sleep.ms"
public static final String	KAFKA_FETCH_MAX_BYTES_CONFIG	"kafka.fetch.max.bytes"
public static final String	KAFKA_FETCH_MAX_SIZE_PER_SEC	"kafka.fetch.max.size.per.sec"
public static final String	KAFKA_FETCH_MAX_WAIT_MS_CONFIG	"kafka.fetch.max.wait.ms"
public static final String	KAFKA_FETCH_MAX_WAIT_TIME_MS	"kafka.fetch.max.wait.time.ms"
public static final String	KAFKA_FETCH_MIN_BYTES_CONFIG	"kafka.fetch.min.bytes"
public static final String	KAFKA_FETCH_MIN_SIZE_PER_SEC	"kafka.fetch.min.size.per.sec"
public static final String	KAFKA_FETCH_PARTITION_MAX_SIZE_PER_SEC	"kafka.fetch.partition.max.size.per.sec"
public static final String	KAFKA_FETCH_QUOTA_BYTES_PER_SECOND	"kafka.fetch.quota.bytes.per.second"
public static final String	KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND	"kafka.fetch.quota.records.per.second"
public static final String	KAFKA_FETCH_QUOTA_TIME_WINDOW_MS	"kafka.fetch.quota.time.window.ms"
public static final String	KAFKA_FETCH_QUOTA_UNORDERED_BYTES_PER_SECOND	"kafka.fetch.quota.unordered.bytes.per.second"
public static final String	KAFKA_FETCH_QUOTA_UNORDERED_RECORDS_PER_SECOND	"kafka.fetch.quota.unordered.records.per.second"
public static final String	KAFKA_FETCH_THROTTLER_FACTORS_PER_SECOND	"kafka.fetch.throttler.factors.per.second"
public static final String	KAFKA_GROUP_ID_CONFIG	"kafka.group.id"
public static final String	KAFKA_LINGER_MS	"kafka.linger.ms"
public static final String	KAFKA_LOG_COMPACTION_FOR_HYBRID_STORES	"kafka.log.compaction.for.hybrid.stores"
public static final String	KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG	"kafka.max.partition.fetch.bytes"
public static final String	KAFKA_MAX_POLL_RECORDS_CONFIG	"kafka.max.poll.records"
public static final String	KAFKA_MIN_IN_SYNC_REPLICAS	"kafka.min.in.sync.replicas"
public static final String	KAFKA_MIN_IN_SYNC_REPLICAS_ADMIN_TOPICS	"kafka.min.in.sync.replicas.admin.topics"
public static final String	KAFKA_MIN_IN_SYNC_REPLICAS_RT_TOPICS	"kafka.min.in.sync.replicas.rt.topics"
public static final String	KAFKA_OVER_SSL	"kafka.over.ssl"
public static final String	KAFKA_PRODUCER_DELIVERY_TIMEOUT_MS	"kafka.delivery.timeout.ms"
public static final String	KAFKA_PRODUCER_REQUEST_TIMEOUT_MS	"kafka.request.timeout.ms"
public static final String	KAFKA_PRODUCER_RETRIES_CONFIG	"kafka.retries"
public static final String	KAFKA_READ_CYCLE_DELAY_MS	"kafka.read.cycle.delay.ms"
public static final String	KAFKA_REPLICATION_FACTOR	"kafka.replication.factor"
public static final String	KAFKA_REPLICATION_FACTOR_RT_TOPICS	"kafka.replication.factor.rt.topics"
public static final String	KAFKA_SECURITY_PROTOCOL_LEGACY	"kafka.security.protocol"
public static final String	KEY_URN_COMPRESSION_ENABLED	"key.urn.compression.enabled"
public static final String	KEY_VALUE_PROFILING_ENABLED	"key.value.profiling.enabled"
public static final String	KME_REGISTRATION_FROM_MESSAGE_HEADER_ENABLED	"kme.registration.from.message.header.enabled"
public static final String	KME_SCHEMA_READER_FOR_SCHEMA_EVOLUTION_ENABLED	"kme.schema.reader.for.schema.evolution.enabled"
public static final String	LEADER_FOLLOWER_STATE_TRANSITION_THREAD_POOL_STRATEGY	"leader.follower.state.transition.thread.pool.strategy"
public static final String	LEAKED_PUSH_STATUS_CLEAN_UP_SERVICE_SLEEP_INTERVAL_MS	"leaked.push.status.clean.up.service.interval.ms"
public static final String	LEAKED_RESOURCE_ALLOWED_LINGER_TIME_MS	"leaked.resource.allowed.linger.time.ms"
public static final String	LISTENER_HOSTNAME	"listener.hostname"
public static final String	LISTENER_PORT	"listener.port"
public static final String	LISTENER_SSL_PORT	"listener.ssl.port"
public static final String	LOCAL_CONTROLLER_D2_SERVICE_NAME	"local.controller.d2.service.name"
public static final String	LOCAL_CONTROLLER_URL	"local.controller.url"
public static final String	LOCAL_D2_ZK_HOST	"local.d2.zk.host"
public static final String	LOCAL_REGION_NAME	"local.region.name"
public static final String	LOG_COMPACTION_DUPLICATE_KEY_THRESHOLD	"log.compaction.duplicate.key.threshold"
public static final String	LOG_COMPACTION_ENABLED	"log.compaction.enabled"
public static final String	LOG_COMPACTION_INTERVAL_MS	"log.compaction.interval.ms"
public static final String	LOG_COMPACTION_SCHEDULING_ENABLED	"log.compaction.scheduling.enabled"
public static final String	LOG_COMPACTION_THREAD_COUNT	"log.compaction.thread.count"
public static final String	LOG_COMPACTION_THRESHOLD_MS	"log.compaction.threshold.ms"
public static final String	LOG_COMPACTION_VERSION_STALENESS_THRESHOLD_MS	"log.compaction.version.staleness.threshold.ms"
public static final String	MAX_FUTURE_VERSION_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER	"max.future.version.leader.follower.state.transition.thread.number"
public static final String	MAX_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER	"max.leader.follower.state.transition.thread.number"
public static final String	MAX_ONLINE_OFFLINE_STATE_TRANSITION_THREAD_NUMBER	"max.state.transition.thread.number"
public static final String	MAX_READ_CAPACITY	"max.read.capacity"
public static final String	META_STORE_WRITER_CLOSE_CONCURRENCY	"meta.store.writer.close.concurrency"
public static final String	META_STORE_WRITER_CLOSE_TIMEOUT_MS	"meta.store.writer.close.timeout.ms"
public static final String	MIN_CONSUMER_IN_CONSUMER_POOL_PER_KAFKA_CLUSTER	"min.consumer.in.consumer.pool.per.kafka.cluster"
public static final String	MIN_NUMBER_OF_STORE_VERSIONS_TO_PRESERVE	"min.number.of.store.versions.to.preserve"
public static final String	MIN_NUMBER_OF_UNUSED_KAFKA_TOPICS_TO_PRESERVE	"min.number.of.unused.kafka.topics.to.preserve"
public static final String	MULTI_REGION	"multi.region"
public static final String	MULTITASK_SCHEDULER_SERVICE_ENABLED	"multitask.scheduler.service.enabled"
public static final String	NAME_REPOSITORY_MAX_ENTRY_COUNT	"name.repository.max.entry.count"
public static final String	NATIVE_REPLICATION_FABRIC_ALLOWLIST	"native.replication.fabric.allowlist"
public static final String	NATIVE_REPLICATION_FABRIC_WHITELIST	"native.replication.fabric.whitelist"
public static final String	NATIVE_REPLICATION_SOURCE_FABRIC	"native.replication.source.fabric"
public static final String	NATIVE_REPLICATION_SOURCE_FABRIC_AS_DEFAULT_FOR_BATCH_ONLY_STORES	"native.replication.source.fabric.as.default.for.batch.only.stores"
public static final String	NATIVE_REPLICATION_SOURCE_FABRIC_AS_DEFAULT_FOR_HYBRID_STORES	"native.replication.source.fabric.as.default.for.hybrid.stores"
public static final String	OFFLINE_JOB_START_TIMEOUT_MS	"offline.job.start.timeout.ms"
public static final String	OFFSET_LAG_DELTA_RELAX_FACTOR_FOR_FAST_ONLINE_TRANSITION_IN_RESTART	"offset.lag.delta.relax.factor.for.fast.online.transition.in.restart"
public static final String	PARENT_CONTROLLER_MAX_ERRORED_TOPIC_NUM_TO_KEEP	"parent.controller.max.errored.topic.num.to.keep"
public static final String	PARENT_CONTROLLER_METADATA_STORE_CLUSTER_NAME	"parent.controller.metadata.store.cluster.name"
public static final String	PARENT_CONTROLLER_WAITING_TIME_FOR_CONSUMPTION_MS	"parent.controller.waiting.time.for.consumption.ms"
public static final String	PARENT_KAFKA_CLUSTER_FABRIC_LIST	"parent.kafka.cluster.fabric.list"
public static final String	PARTICIPANT_MESSAGE_CONSUMPTION_DELAY_MS	"participant.message.consumption.delay.ms"
public static final String	PARTICIPANT_MESSAGE_STORE_ENABLED	"participant.message.store.enabled"
public static final String	PARTITION_COUNT_ROUND_UP_SIZE	"partition.count.round.up.size"
public static final String	PARTITIONER_CLASS	"partitioner.class"
public static final String	PASS_THROUGH_CONFIG_PREFIXES_LIST_KEY	"pass.through.config.prefixes.list"
public static final String	PERSISTENCE_TYPE	"persistence.type"
public static final String	PUB_SUB_ADMIN_ADAPTER_FACTORY_CLASS	"pub.sub.admin.adapter.factory.class"
public static final String	PUB_SUB_CONSUMER_ADAPTER_FACTORY_CLASS	"pub.sub.consumer.adapter.factory.class"
public static final String	PUB_SUB_PRODUCER_ADAPTER_FACTORY_CLASS	"pub.sub.producer.adapter.factory.class"
public static final String	PUB_SUB_SOURCE_OF_TRUTH_ADMIN_ADAPTER_FACTORY_CLASS	"pub.sub.of.source.of.truth.admin.adapter.factory.class"
public static final String	PUBSUB_ADMIN_ADAPTER_FACTORY_CLASS	"pubsub.admin.adapter.factory.class"
public static final String	PUBSUB_BROKER_ADDRESS	"pubsub.broker.address"
public static final String	PUBSUB_CLIENT_CONFIG_PREFIX	"pubsub."
public static final String	PUBSUB_CONSUMER_ADAPTER_FACTORY_CLASS	"pubsub.consumer.adapter.factory.class"
public static final String	PUBSUB_PRODUCER_ADAPTER_FACTORY_CLASS	"pubsub.producer.adapter.factory.class"
public static final String	PUBSUB_SECURITY_PROTOCOL	"pubsub.security.protocol"
public static final String	PUBSUB_SECURITY_PROTOCOL_LEGACY	"security.protocol"
public static final String	PUBSUB_SOURCE_OF_TRUTH_ADMIN_ADAPTER_FACTORY_CLASS	"pubsub.source.of.truth.admin.adapter.factory.class"
public static final String	PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE	"pubsub.topic.manager.metadata.fetcher.consumer.pool.size"
public static final String	PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_THREAD_POOL_SIZE	"pubsub.topic.manager.metadata.fetcher.thread.pool.size"
public static final String	PUBSUB_TYPE_ID_TO_POSITION_CLASS_NAME_MAP	"pubsub.type.id.to.position.class.name.map"
public static final String	PUSH_JOB_FAILURE_CHECKPOINTS_TO_DEFINE_USER_ERROR	"push.job.failure.checkpoints.to.define.user.error"
public static final String	PUSH_JOB_GUID_LEAST_SIGNIFICANT_BITS	"push.job.guid.least.significant.bits"
public static final String	PUSH_JOB_GUID_MOST_SIGNIFICANT_BITS	"push.job.guid.most.significant.bits"
public static final String	PUSH_JOB_STATUS_STORE_CLUSTER_NAME	"controller.push.job.status.store.cluster.name"
public static final String	PUSH_JOB_VIEW_CONFIGS	"push.job.view.configs"
public static final String	PUSH_SSL_ALLOWLIST	"push.ssl.allowlist"
public static final String	PUSH_SSL_WHITELIST	"push.ssl.whitelist"
public static final String	PUSH_STATUS_INSTANCE_NAME_SUFFIX	"push.status.instance.name.suffix"
public static final String	PUSH_STATUS_STORE_ENABLED	"push.status.store.enabled"
public static final String	PUSH_STATUS_STORE_HEARTBEAT_EXPIRATION_TIME_IN_SECONDS	"push.status.store.heartbeat.expiration.seconds"
public static final String	PUSH_STATUS_STORE_HEARTBEAT_INTERVAL_IN_SECONDS	"push.status.store.heartbeat.interval.seconds"
public static final String	REFRESH_ATTEMPTS_FOR_ZK_RECONNECT	"refresh.attempts.for.zk.reconnect"
public static final String	REFRESH_INTERVAL_FOR_ZK_RECONNECT_MS	"refresh.interval.for.zk.reconnect.ms"
public static final String	REPLICATION_METADATA_VERSION	"replication.metadata.version"
public static final String	REPUSH_CANDIDATE_FILTER_CLASS_NAMES	"controller.repush.candidate.filter.class.names"
public static final String	REPUSH_ORCHESTRATOR_CLASS_NAME	"controller.repush.orchestrator.class.name"
public static final String	ROUTE_DNS_CACHE_HOST_PATTERN	"router.dns.cache.host.pattern"
public static final String	ROUTER_ASYNC_START_ENABLED	"router.async.start.enabled"
public static final String	ROUTER_CLIENT_DECOMPRESSION_ENABLED	"router.client.decompression.enabled"
public static final String	ROUTER_CLIENT_IP_SPOOFING_CHECK_ENABLED	"router.client.ip.spoofing.check.enabled"
public static final String	ROUTER_CLIENT_RESOLUTION_RETRY_ATTEMPTS	"router.client.resolution.retry.attempts"
public static final String	ROUTER_CLIENT_RESOLUTION_RETRY_BACKOFF_MS	"router.client.resolution.retry.backoff.ms"
public static final String	ROUTER_CLIENT_SSL_HANDSHAKE_QUEUE_CAPACITY	"router.client.ssl.handshake.queue.capacity"
public static final String	ROUTER_COMPUTE_TARDY_LATENCY_MS	"router.compute.tardy.latency.ms"
public static final String	ROUTER_CONNECTION_HANDLE_MODE	"router.connection.handle.mode"
public static final String	ROUTER_CONNECTION_LIMIT	"router.connection.limit"
public static final String	ROUTER_CONNECTION_TIMEOUT	"router.connection.timeout"
public static final String	ROUTER_DICTIONARY_PROCESSING_THREADS	"router.dictionary.processing.threads"
public static final String	ROUTER_DICTIONARY_RETRIEVAL_TIME_MS	"router.dictionary.retrieval.time.ms"
public static final String	ROUTER_DNS_CACHE_ENABLED	"router.dns.cache.enabled"
public static final String	ROUTER_DNS_CACHE_REFRESH_INTERVAL_MS	"router.dns.cache.refresh.interval.ms"
public static final String	ROUTER_EARLY_THROTTLE_ENABLED	"router.early.throttle.enabled"
public static final String	ROUTER_ENABLE_READ_THROTTLING	"router.enable.read.throttling"
public static final String	ROUTER_ENABLE_SSL	"router.enable.ssl"
public static final String	ROUTER_FULL_PENDING_QUEUE_SERVER_OOR_MS	"router.full.pending.queue.server.oor.ms"
public static final String	ROUTER_HEART_BEAT_ENABLED	"router.heart.beat.enabled"
public static final String	ROUTER_HELIX_ASSISTED_ROUTING_GROUP_SELECTION_STRATEGY	"router.helix.assisted.routing.group.selection.strategy"
public static final String	ROUTER_HTTP_CLIENT_OPENSSL_ENABLED	"router.http.client.openssl.enabled"
public static final String	ROUTER_HTTP_CLIENT_POOL_SIZE	"router.http.client.pool.size"
public static final String	ROUTER_HTTP_CLIENT5_POOL_SIZE	"router.http.client5.pool.size"
public static final String	ROUTER_HTTP_CLIENT5_SKIP_CIPHER_CHECK_ENABLED	"router.http.client5.skip.cipher.check.enabled"
public static final String	ROUTER_HTTP_CLIENT5_TOTAL_IO_THREAD_COUNT	"router.http.client5.total.io.thread.count"
public static final String	ROUTER_HTTP2_HEADER_TABLE_SIZE	"router.http2.header.table.size"
public static final String	ROUTER_HTTP2_INBOUND_ENABLED	"router.http2.inbound.enabled"
public static final String	ROUTER_HTTP2_INITIAL_WINDOW_SIZE	"router.http2.initial.window.size"
public static final String	ROUTER_HTTP2_MAX_CONCURRENT_STREAMS	"router.http2.max.concurrent.streams"
public static final String	ROUTER_HTTP2_MAX_FRAME_SIZE	"router.http2.max.frame.size"
public static final String	ROUTER_HTTP2_MAX_HEADER_LIST_SIZE	"router.http2.max.header.list.size"
public static final String	ROUTER_HTTPASYNCCLIENT_CLIENT_POOL_THREAD_COUNT	"router.httpasyncclient.client.pool.io.thread.count"
public static final String	ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_ENABLED	"router.httpasyncclient.connection.warming.enabled"
public static final String	ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_EXECUTOR_THREAD_NUM	"router.httpasyncclient.connection.warming.executor.thread.num"
public static final String	ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_LOW_WATER_MARK	"router.httpasyncclient.connection.warming.low.water.mark"
public static final String	ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_NEW_INSTANCE_DELAY_JOIN_MS	"router.httpasyncclient.connection.warming.new.instance.delay.join.ms"
public static final String	ROUTER_HTTPASYNCCLIENT_CONNECTION_WARMING_SLEEP_INTERVAL_MS	"router.httpasyncclient.connection.warming.sleep.interval.ms"
public static final String	ROUTER_HTTPAYSNCCLIENT_CONNECTION_WARMING_SOCKET_TIMEOUT_MS	"router.httpasyncclient.connection.warming.socket.timeout.ms"
public static final String	ROUTER_IDLE_CONNECTION_TO_SERVER_CLEANUP_ENABLED	"router.idle.connection.to.server.cleanup.enabled"
public static final String	ROUTER_IDLE_CONNECTION_TO_SERVER_CLEANUP_THRESHOLD_MINS	"router.idle.connection.to.server.cleanup.threshold.mins"
public static final String	ROUTER_IO_WORKER_COUNT	"router.io.worker.count"
public static final String	ROUTER_LATENCY_BASED_ROUTING_ENABLED	"router.latency.based.routing.enabled"
public static final String	ROUTER_LEAKED_FUTURE_CLEANUP_POLL_INTERVAL_MS	"router.leaked.future.cleanup.poll.interval.ms"
public static final String	ROUTER_LEAKED_FUTURE_CLEANUP_THRESHOLD_MS	"router.leaked.future.cleanup.threshold.ms"
public static final String	ROUTER_LONG_TAIL_RETRY_BUDGET_ENFORCEMENT_WINDOW_MS	"router.long.tail.retry.budget.enforcement.window.ms"
public static final String	ROUTER_LONG_TAIL_RETRY_FOR_BATCH_GET_THRESHOLD_MS	"router.long.tail.retry.for.batch.get.threshold.ms"
public static final String	ROUTER_LONG_TAIL_RETRY_FOR_SINGLE_GET_THRESHOLD_MS	"router.long.tail.retry.for.single.get.threshold.ms"
public static final String	ROUTER_LONG_TAIL_RETRY_MAX_ROUTE_FOR_MULTI_KEYS_REQ	"router.long.tail.retry.max.route.for.multi.keys.req"
public static final String	ROUTER_MAX_CONCURRENT_SSL_HANDSHAKES	"router.max.concurrent.ssl.handshakes"
public static final String	ROUTER_MAX_KEY_COUNT_IN_MULTIGET_REQ	"router.max.key_count.in.multiget.req"
public static final String	ROUTER_MAX_OUTGOING_CONNECTION	"router.max.outgoing.connection"
public static final String	ROUTER_MAX_OUTGOING_CONNECTION_PER_ROUTE	"router.max.outgoing.connection.per.route"
public static final String	ROUTER_MAX_PENDING_REQUEST	"router.max.pending.request"
public static final String	ROUTER_MAX_READ_CAPACITY	"router.max.read.capacity"
public static final String	ROUTER_META_STORE_SHADOW_READ_ENABLED	"router.meta.store.shadow.read.enabled"
public static final String	ROUTER_MULTI_KEY_LONG_TAIL_RETRY_BUDGET_PERCENT_DECIMAL	"router.multi.key.long.tail.retry.budget.percent.decimal"
public static final String	ROUTER_MULTI_KEY_ROUTING_STRATEGY	"router.multi.key.routing.strategy"
public static final String	ROUTER_MULTIGET_TARDY_LATENCY_MS	"router.multiget.tardy.latency.ms"
public static final String	ROUTER_NETTY_GRACEFUL_SHUTDOWN_PERIOD_SECONDS	"router.netty.graceful.shutdown.period.seconds"
public static final String	ROUTER_PARALLEL_ROUTING_CHUNK_SIZE	"router.parallel.routing.chunk.size"
public static final String	ROUTER_PARALLEL_ROUTING_THREAD_POOL_SIZE	"router.parallel.routing.thread.pool.size"
public static final String	ROUTER_PENDING_CONNECTION_RESUME_THRESHOLD_PER_ROUTE	"router.pending.connection.resume.threshold.per.host"
public static final String	ROUTER_PER_NODE_CLIENT_ENABLED	"router.per.node.client.enabled"
public static final String	ROUTER_PER_NODE_CLIENT_THREAD_COUNT	"router.per.node.client.thread.count"
public static final String	ROUTER_PER_STORE_ROUTER_QUOTA_BUFFER	"router.per.store.router.quota.buffer"
public static final String	ROUTER_PRINCIPAL_NAME	"router.principal.name"
public static final String	ROUTER_QUOTA_CHECK_WINDOW	"router.quota.check.window"
public static final String	ROUTER_READ_QUOTA_THROTTLING_LEASE_TIMEOUT_MS	"router.read.quota.throttling.lease.timeout.ms"
public static final String	ROUTER_RESOLVE_QUEUE_CAPACITY	"router.resolve.queue.capacity"
public static final String	ROUTER_RESOLVE_THREADS	"router.resolve.threads"
public static final String	ROUTER_RETRY_MANAGER_CORE_POOL_SIZE	"router.retry.manager.core.pool.size"
public static final String	ROUTER_ROUTING_COMPUTATION_MODE	"router.routing.computation.mode"
public static final String	ROUTER_SINGLE_KEY_LONG_TAIL_RETRY_BUDGET_PERCENT_DECIMAL	"router.single.key.long.tail.retry.budget.percent.decimal"
public static final String	ROUTER_SINGLEGET_TARDY_LATENCY_MS	"router.singleget.tardy.latency.ms"
public static final String	ROUTER_SMART_LONG_TAIL_RETRY_ABORT_THRESHOLD_MS	"router.smart.long.tail.retry.abort.threshold.ms"
public static final String	ROUTER_SMART_LONG_TAIL_RETRY_ENABLED	"router.smart.long.tail.retry.enabled"
public static final String	ROUTER_SOCKET_TIMEOUT	"router.socket.timeout"
public static final String	ROUTER_STATEFUL_HEALTHCHECK_ENABLED	"router.stateful.healthcheck.enabled"
public static final String	ROUTER_STORAGE_NODE_CLIENT_TYPE	"router.storage.node.client.type"
public static final String	ROUTER_UNHEALTHY_PENDING_CONNECTION_THRESHOLD_PER_ROUTE	"router.unhealthy.pending.connection.threshold.per.host"
public static final String	ROUTER_USE_LOCAL_SSL_SETTINGS	"router.local.ssl"
public static final String	SERVER_AA_WC_INGESTION_STORAGE_LOOKUP_THREAD_POOL_SIZE	"server.aa.wc.ingestion.storage.lookup.thread.pool.size"
public static final String	SERVER_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND	"server.aa.wc.leader.quota.records.per.second"
public static final String	SERVER_AA_WC_WORKLOAD_PARALLEL_PROCESSING_ENABLED	"server.aa.wc.workload.parallel.processing.enabled"
public static final String	SERVER_AA_WC_WORKLOAD_PARALLEL_PROCESSING_THREAD_POOL_SIZE	"server.aa.wc.workload.parallel.processing.thread.pool.size"
public static final String	SERVER_ADAPTIVE_THROTTLER_ENABLED	"server.adaptive.throttler.enabled"
public static final String	SERVER_ADAPTIVE_THROTTLER_MULTI_GET_LATENCY_THRESHOLD	"server.adaptive.throttler.multi.get.latency.threshold"
public static final String	SERVER_ADAPTIVE_THROTTLER_READ_COMPUTE_GET_LATENCY_THRESHOLD	"server.adaptive.throttler.read.compute.latency.threshold"
public static final String	SERVER_ADAPTIVE_THROTTLER_SIGNAL_IDLE_THRESHOLD	"server.adaptive.throttler.signal.idle.threshold"
public static final String	SERVER_ADAPTIVE_THROTTLER_SIGNAL_REFRESH_INTERVAL_IN_SECONDS	"server.adaptive.throttler.signal.refresh.interval.in.seconds"
public static final String	SERVER_ADAPTIVE_THROTTLER_SINGLE_GET_LATENCY_THRESHOLD	"server.adaptive.throttler.single.get.latency.threshold"
public static final String	SERVER_BATCH_REPORT_END_OF_INCREMENTAL_PUSH_STATUS_ENABLED	"server.batch.report.end.of.incremental.push.status.enabled"
public static final String	SERVER_BLOB_TRANSFER_ADAPTIVE_THROTTLER_ENABLED	"server.blob.transfer.adaptive.throttler.enabled"
public static final String	SERVER_BLOB_TRANSFER_ADAPTIVE_THROTTLER_UPDATE_PERCENTAGE	"server.blob.transfer.adaptive.throttler.update.percentage"
public static final String	SERVER_BLOCKING_QUEUE_TYPE	"server.blocking.queue.type"
public static final String	SERVER_CHANNEL_OPTION_WRITE_BUFFER_WATERMARK_HIGH_BYTES	"server.channel.option.write.buffer.watermark.high.bytes"
public static final String	SERVER_COMPUTE_FAST_AVRO_ENABLED	"server.compute.fast.avro.enabled"
public static final String	SERVER_COMPUTE_QUEUE_CAPACITY	"server.compute.queue.capacity"
public static final String	SERVER_COMPUTE_THREAD_NUM	"server.compute.thread.num"
public static final String	SERVER_CONSUMER_POLL_TRACKER_STALE_THRESHOLD_IN_SECONDS	"server.consumer.poll.tracker.stale.threshold.in.seconds"
public static final String	SERVER_CONSUMER_POOL_ALLOCATION_STRATEGY	"server.consumer.pool.allocation.strategy"
public static final String	SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_AA_WC_LEADER	"server.consumer.pool.size.for.current.version.aa.wc.leader"
public static final String	SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_NON_AA_WC_LEADER	"server.consumer.pool.size.for.current.version.non.aa.wc.leader"
public static final String	SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER	"server.consumer.pool.size.for.current.version.separate.rt.leader"
public static final String	SERVER_CONSUMER_POOL_SIZE_FOR_NON_CURRENT_VERSION_AA_WC_LEADER	"server.consumer.pool.size.for.non.current.version.aa.wc.leader"
public static final String	SERVER_CONSUMER_POOL_SIZE_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER	"server.consumer.pool.size.for.non.current.version.non.aa.wc.leader"
public static final String	SERVER_CONSUMER_POOL_SIZE_PER_KAFKA_CLUSTER	"server.consumer.pool.size.per.kafka.cluster"
public static final String	SERVER_CURRENT_VERSION_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND	"server.current.version.aa.wc.leader.quota.records.per.second"
public static final String	SERVER_CURRENT_VERSION_NON_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND	"server.current.version.non.aa.wc.leader.quota.records.per.second"
public static final String	SERVER_CURRENT_VERSION_SEPARATE_RT_LEADER_QUOTA_RECORDS_PER_SECOND	"server.current.version.separate.rt.leader.quota.records.per.second"
public static final String	SERVER_DATABASE_CHECKSUM_VERIFICATION_ENABLED	"server.database.checksum.verification.enabled"
public static final String	SERVER_DATABASE_LOOKUP_QUEUE_CAPACITY	"server.database.lookup.queue.capacity"
public static final String	SERVER_DATABASE_MEMORY_STATS_ENABLED	"server.database.memory.stats.enabled"
public static final String	SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_DEFERRED_WRITE_MODE	"server.database.sync.bytes.interval.for.deferred.write.mode"
public static final String	SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_TRANSACTIONAL_MODE	"server.database.sync.bytes.interval.for.transactional.mode"
public static final String	SERVER_DB_READ_ONLY_FOR_BATCH_ONLY_STORE_ENABLED	"server.db.read.only.for.batch.only.store.enabled"
public static final String	SERVER_DEBUG_LOGGING_ENABLED	"server.debug.logging.enabled"
public static final String	SERVER_DEDICATED_CONSUMER_POOL_FOR_AA_WC_LEADER_ENABLED	"server.dedicated.consumer.pool.for.aa.wc.leader.enabled"
public static final String	SERVER_DEDICATED_CONSUMER_POOL_SIZE_FOR_AA_WC_LEADER	"server.dedicated.consumer.pool.size.for.aa.wc.leader"
public static final String	SERVER_DEDICATED_CONSUMER_POOL_SIZE_FOR_SEP_RT_LEADER	"server.dedicated.consumer.pool.size.for.sep.rt.leader"
public static final String	SERVER_DEDICATED_DRAINER_FOR_SORTED_INPUT_ENABLED	"server.dedicated.drainer.queue.for.sorted.input.enabled"
public static final String	SERVER_DELETE_UNASSIGNED_PARTITIONS_ON_STARTUP	"server.delete.unassigned.partitions.on.startup"
public static final String	SERVER_DISK_FULL_THRESHOLD	"disk.full.threshold"
public static final String	SERVER_DISK_HEALTH_CHECK_INTERVAL_IN_SECONDS	"server.disk.health.check.interval.in.seconds"
public static final String	SERVER_DISK_HEALTH_CHECK_SERVICE_ENABLED	"server.disk.health.check.service.enabled"
public static final String	SERVER_DISK_HEALTH_CHECK_TIMEOUT_IN_SECONDS	"server.disk.health.check.timeout.in.seconds"
public static final String	SERVER_ENABLE_LIVE_CONFIG_BASED_KAFKA_THROTTLING	"server.enable.live.config.based.kafka.throttling"
public static final String	SERVER_ENABLE_PARALLEL_BATCH_GET	"server.enable.parallel.batch.get"
public static final String	SERVER_FORKED_PROCESS_JVM_ARGUMENT_LIST	"server.forked.process.jvm.arg.list"
public static final String	SERVER_GLOBAL_RT_DIV_ENABLED	"server.global.rt.div.enabled"
public static final String	SERVER_HELIX_JOIN_AS_UNKNOWN	"server.helix.join.as.unknown"
public static final String	SERVER_HTTP2_HEADER_TABLE_SIZE	"server.http2.header.table.size"
public static final String	SERVER_HTTP2_INBOUND_ENABLED	"server.http2.inbound.enabled"
public static final String	SERVER_HTTP2_INITIAL_WINDOW_SIZE	"server.http2.initial.window.size"
public static final String	SERVER_HTTP2_MAX_CONCURRENT_STREAMS	"server.http2.max.concurrent.streams"
public static final String	SERVER_HTTP2_MAX_FRAME_SIZE	"server.http2.max.frame.size"
public static final String	SERVER_HTTP2_MAX_HEADER_LIST_SIZE	"server.http2.max.header.list.size"
public static final String	SERVER_IDLE_INGESTION_TASK_CLEANUP_INTERVAL_IN_SECONDS	"server.idle.ingestion.task.cleanup.interval.in.seconds"
public static final String	SERVER_INACTIVE_TOPIC_PARTITION_CHECKER_ENABLED	"server.inactive.topic.partition.checker.enabled"
public static final String	SERVER_INACTIVE_TOPIC_PARTITION_CHECKER_INTERNAL_IN_SECONDS	"server.inactive.topic.partition.checker.internal.in.seconds"
public static final String	SERVER_INACTIVE_TOPIC_PARTITION_CHECKER_THRESHOLD_IN_SECONDS	"server.inactive.topic.partition.checker.threshold.in.seconds"
public static final String	SERVER_INCREMENTAL_PUSH_STATUS_WRITE_MODE	"server.incremental.push.status.write.mode"
public static final String	SERVER_INGESTION_CHECKPOINT_DURING_GRACEFUL_SHUTDOWN_ENABLED	"server.ingestion.checkpoint.during.graceful.shutdown.enabled"
public static final String	SERVER_INGESTION_HEARTBEAT_INTERVAL_MS	"server.ingestion.heartbeat.interval.ms"
public static final String	SERVER_INGESTION_INFO_LOG_LINE_LIMIT	"server.ingestion.info.log.line.limit"
public static final String	SERVER_INGESTION_ISOLATION_ACL_ENABLED	"server.ingestion.isolation.acl.enabled"
public static final String	SERVER_INGESTION_ISOLATION_APPLICATION_PORT	"server.ingestion.isolation.application.port"
public static final String	SERVER_INGESTION_ISOLATION_CONNECTION_TIMEOUT_SECONDS	"server.ingestion.isolation.connection.timeout.seconds"
public static final String	SERVER_INGESTION_ISOLATION_D2_CLIENT_ENABLED	"server.ingestion.isolation.d2.client.enabled"
public static final String	SERVER_INGESTION_ISOLATION_HEARTBEAT_REQUEST_TIMEOUT_SECONDS	"server.ingestion.isolation.heartbeat.request.timeout.seconds"
public static final String	SERVER_INGESTION_ISOLATION_PRINCIPAL_NAME	"server.ingestion.isolation.principal.name"
public static final String	SERVER_INGESTION_ISOLATION_REQUEST_TIMEOUT_SECONDS	"server.ingestion.isolation.request.timeout.seconds"
public static final String	SERVER_INGESTION_ISOLATION_SERVICE_PORT	"server.ingestion.isolation.service.port"
public static final String	SERVER_INGESTION_ISOLATION_SSL_ENABLED	"server.ingestion.isolation.ssl.enabled"
public static final String	SERVER_INGESTION_ISOLATION_STATS_CLASS_LIST	"server.ingestion.isolation.stats.class.list"
public static final String	SERVER_INGESTION_MODE	"server.ingestion.mode"
public static final String	SERVER_INGESTION_TASK_MAX_IDLE_COUNT	"server.ingestion.task.max.idle.count"
public static final String	SERVER_INGESTION_TASK_REUSABLE_OBJECTS_STRATEGY	"server.ingestion.task.reusable.objects.strategy"
public static final String	SERVER_KAFKA_CONSUMER_OFFSET_COLLECTION_ENABLED	"server.kafka.consumer.offset.collection.enabled"
public static final String	SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND	"server.kafka.fetch.quota.records.per.second"
public static final String	SERVER_KAFKA_MAX_POLL_RECORDS	"server.kafka.max.poll.records"
public static final String	SERVER_LEADER_COMPLETE_STATE_CHECK_IN_FOLLOWER_VALID_INTERVAL_MS	"server.leader.complete.state.check.in.follower.valid.interval.ms"
public static final String	SERVER_LEAKED_RESOURCE_CLEAN_UP_INTERVAL_IN_MINUTES	"server.leaked.resource.clean.up.interval.in.minutes"
public static final String	SERVER_LEAKED_RESOURCE_CLEANUP_ENABLED	"server.leaked.resource.cleanup.enabled"
public static final String	SERVER_LOAD_CONTROLLER_ACCEPT_MULTIPLIER	"server.load.controller.accept.multiplier"
public static final String	SERVER_LOAD_CONTROLLER_COMPUTE_LATENCY_ACCEPT_THRESHOLD_IN_MS	"server.load.controller.compute.latency.accept.threshold.in.ms"
public static final String	SERVER_LOAD_CONTROLLER_ENABLED	"server.load.controller.enabled"
public static final String	SERVER_LOAD_CONTROLLER_MAX_REJECTION_RATIO	"server.load.controller.max.rejection.ratio"
public static final String	SERVER_LOAD_CONTROLLER_MULTI_GET_LATENCY_ACCEPT_THRESHOLD_IN_MS	"server.load.controller.multi.get.latency.accept.threshold.in.ms"
public static final String	SERVER_LOAD_CONTROLLER_REJECTION_RATIO_UPDATE_INTERNAL_IN_SECONDS	"server.load.controller.rejection.ratio.update.internal.in.seconds"
public static final String	SERVER_LOAD_CONTROLLER_SINGLE_GET_LATENCY_ACCEPT_THRESHOLD_IN_MS	"server.load.controller.single.get.latency.accept.threshold.in.ms"
public static final String	SERVER_LOAD_CONTROLLER_WINDOW_SIZE_IN_SECONDS	"server.load.controller.window.size.in.seconds"
public static final String	SERVER_LOCAL_CONSUMER_CONFIG_PREFIX	"server.local.consumer.config.prefix."
public static final String	SERVER_MAX_REQUEST_SIZE	"server.max.request.size"
public static final String	SERVER_MAX_WAIT_AFTER_UNSUBSCRIBE_MS	"server.max.wait.after.unsubscribe.ms"
public static final String	SERVER_MAX_WAIT_FOR_VERSION_INFO_MS_CONFIG	"server.max.wait.for.version.info.ms"
public static final String	SERVER_NEARLINE_WORKLOAD_PRODUCER_THROUGHPUT_OPTIMIZATION_ENABLED	"server.nearline.workload.producer.throughput.optimization.enabled"
public static final String	SERVER_NETTY_GRACEFUL_SHUTDOWN_PERIOD_SECONDS	"server.netty.graceful.shutdown.period.seconds"
public static final String	SERVER_NETTY_IDLE_TIME_SECONDS	"server.netty.idle.time.seconds"
public static final String	SERVER_NETTY_WORKER_THREADS	"server.netty.worker.threads"
public static final String	SERVER_NODE_CAPACITY_RCU	"server.node.capacity.rcu.per.second"
public static final String	SERVER_NON_CURRENT_VERSION_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND	"server.non.current.version.aa.wc.leader.quota.records.per.second"
public static final String	SERVER_NON_CURRENT_VERSION_NON_AA_WC_LEADER_QUOTA_RECORDS_PER_SECOND	"server.non.current.version.non.aa.wc.leader.quota.records.per.second"
public static final String	SERVER_NON_EXISTING_TOPIC_CHECK_RETRY_INTERNAL_SECOND	"server.non.existing.topic.check.retry.interval.second"
public static final String	SERVER_NON_EXISTING_TOPIC_INGESTION_TASK_KILL_THRESHOLD_SECOND	"server.non.existing.topic.ingestion.task.kill.threshold.second"
public static final String	SERVER_NUM_SCHEMA_FAST_CLASS_WARMUP	"server.num.schema.fast.class.warmup"
public static final String	SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_ENABLED	"server.optimize.database.for.backup.version.enabled"
public static final String	SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_NO_READ_THRESHOLD_SECONDS	"server.optimize.database.for.backup.version.no.read.threshold.seconds"
public static final String	SERVER_OPTIMIZE_DATABASE_SERVICE_SCHEDULE_INTERNAL_SECONDS	"server.optimize.database.service.schedule.internal.seconds"
public static final String	SERVER_PARALLEL_BATCH_GET_CHUNK_SIZE	"server.parallel.batch.get.chunk.size"
public static final String	SERVER_PARALLEL_RESOURCE_SHUTDOWN_ENABLED	"server.parallel.resource.shutdown.enabled"
public static final String	SERVER_PARTITION_GRACEFUL_DROP_DELAY_IN_SECONDS	"server.partition.graceful.drop.time.in.seconds"
public static final String	SERVER_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS	"server.promotion.to.leader.replica.delay.seconds"
public static final String	SERVER_PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS	"server.pubsub.consumer.poll.retry.backoff.ms"
public static final String	SERVER_PUBSUB_CONSUMER_POLL_RETRY_TIMES	"server.pubsub.consumer.poll.retry.times"
public static final String	SERVER_QUOTA_ENFORCEMENT_CAPACITY_MULTIPLE	"server.quota.enforcement.capacity.multiple"
public static final String	SERVER_QUOTA_ENFORCEMENT_ENABLED	"server.quota.enforcement.enabled"
public static final String	SERVER_QUOTA_ENFORCEMENT_INTERVAL_IN_MILLIS	"server.quota.enforcement.interval.in.millis"
public static final String	SERVER_RECORD_LEVEL_METRICS_WHEN_BOOTSTRAPPING_CURRENT_VERSION_ENABLED	"server.record.level.metrics.when.bootstrapping.current.version.enabled"
public static final String	SERVER_REMOTE_CONSUMER_CONFIG_PREFIX	"server.remote.consumer.config.prefix."
public static final String	SERVER_REMOTE_INGESTION_REPAIR_SLEEP_INTERVAL_SECONDS	"server.remote.ingestion.repair.sleep.interval.seconds"
public static final String	SERVER_RESET_ERROR_REPLICA_ENABLED	"server.reset.error.replica.enabled"
public static final String	SERVER_REST_SERVICE_EPOLL_ENABLED	"server.rest.service.epoll.enabled"
public static final String	SERVER_REST_SERVICE_STORAGE_THREAD_NUM	"server.rest.service.storage.thread.num"
public static final String	SERVER_RESUBSCRIPTION_TRIGGERED_BY_VERSION_INGESTION_CONTEXT_CHANGE_ENABLED	"server.resubscription.triggered.by.version.ingestion.context.change.enabled"
public static final String	SERVER_ROCKSDB_STORAGE_CONFIG_CHECK_ENABLED	"server.rocksdb.storage.config.check.enabled"
public static final String	SERVER_ROUTER_CONNECTION_WARMING_DELAY_MS	"server.router.connection.warming.delay.ms"
public static final String	SERVER_SCHEMA_FAST_CLASS_WARMUP_TIMEOUT	"server.schema.fast.class.warmup.timeout"
public static final String	SERVER_SCHEMA_PRESENCE_CHECK_ENABLED	"server.schema.presence.check.enabled"
public static final String	SERVER_SEP_RT_LEADER_QUOTA_RECORDS_PER_SECOND	"server.sep.rt.leader.quota.records.per.second"
public static final String	SERVER_SHARED_CONSUMER_ASSIGNMENT_STRATEGY	"server.shared.consumer.assignment.strategy"
public static final String	SERVER_SHARED_CONSUMER_NON_EXISTING_TOPIC_CLEANUP_DELAY_MS	"server.shared.cosnumer.non.existing.topic.cleanup.delay.ms"
public static final String	SERVER_SHUTDOWN_DISK_UNHEALTHY_TIME_MS	"server.shutdown.ssd.unhealthy.time.ms"
public static final String	SERVER_SKIP_CHECK_AFTER_UNSUB_ENABLED	"server.skip.check.after.unsub.enabled"
public static final String	SERVER_SOURCE_TOPIC_OFFSET_CHECK_INTERVAL_MS	"server.source.topic.offset.check.interval.ms"
public static final String	SERVER_SSL_HANDSHAKE_QUEUE_CAPACITY	"server.ssl.handshake.queue.capacity"
public static final String	SERVER_SSL_HANDSHAKE_THREAD_POOL_SIZE	"server.ssl.handshake.thread.pool.size"
public static final String	SERVER_STOP_CONSUMPTION_TIMEOUT_IN_SECONDS	"server.stop.consumption.timeout.in.seconds"
public static final String	SERVER_STORAGE_NODE_RATE_LIMITER	"server.storage.node.rate.limiter"
public static final String	SERVER_STORE_TO_EARLY_TERMINATION_THRESHOLD_MS_MAP	"server.store.to.early.termination.threshold.ms.map"
public static final String	SERVER_STORE_VERSION_QPS_RATE_LIMITER	"server.store.version.qps.rate.limiter"
public static final String	SERVER_STUCK_CONSUMER_REPAIR_ENABLED	"server.stuck.consumer.repair.enabled"
public static final String	SERVER_STUCK_CONSUMER_REPAIR_INTERVAL_SECOND	"server.stuck.consumer.repair.second"
public static final String	SERVER_STUCK_CONSUMER_REPAIR_THRESHOLD_SECOND	"server.stuck.consumer.repair.threshold.second"
public static final String	SERVER_SYSTEM_STORE_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS	"server.system.store.promotion.to.leader.replica.delay.seconds"
public static final String	SERVER_THROTTLER_FACTORS_FOR_AA_WC_LEADER	"server_throttler_factors_for_aa_wc_leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER	"server.throttler.factors.for.current.version.aa.wc.leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER	"server.throttler.factors.for.current.version.non.aa.wc.leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER	"server.throttler.factors.for.current.version.separate.rt.leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER	"server.throttler.factors.for.non.current.version.aa.wc.leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER	"server.throttler.factors.for.non.current.version.non.aa.wc.leader"
public static final String	SERVER_THROTTLER_FACTORS_FOR_SEP_RT_LEADER	"server.throttler.factors.for.sep.rt.leader"
public static final String	SERVER_UNSUB_AFTER_BATCHPUSH	"server.unsub.after.batch.push"
public static final String	SERVER_USE_HEARTBEAT_LAG_FOR_READY_TO_SERVE_CHECK_ENABLED	"server.use.heartbeat.lag.for.ready.to.serve.check.enabled"
public static final String	SERVER_USE_METRICS_BASED_POSITION_IN_LAG_COMPUTATION	"server.use.metrics.based.position.in.lag.computation"
public static final String	SERVER_ZSTD_DICT_COMPRESSION_LEVEL	"server.zstd.dict.compression.level"
public static final String	SERVICE_DISCOVERY_REGISTRATION_RETRY_MS	"service.discovery.registration.retry.ms"
public static final String	SEVER_CALCULATE_QUOTA_USAGE_BASED_ON_PARTITIONS_ASSIGNMENT_ENABLED	"server.calculate.quota.usage.based.on.partitions.assignment.enabled"
public static final String	SKIP_DEFERRED_VERSION_SWAP_FOR_DVC_ENABLED	"skip.deferred.version.swap.for.dvc.enabled"
public static final String	SKIP_HYBRID_STORE_RT_TOPIC_COMPACTION_POLICY_UPDATE_ENABLED	"skip.hybrid.store.rt.topic.compaction.policy.update.enabled"
public static final String	SORTED_INPUT_DRAINER_SIZE	"sorted.input.drainer.size"
public static final String	SSL_KAFKA_BOOTSTRAP_SERVERS	"ssl.kafka.bootstrap.servers"
public static final String	SSL_TO_KAFKA_LEGACY	"ssl.to.kakfa"
public static final String	SSL_TO_STORAGE_NODES	"sslToStorageNodes"
public static final String	STORAGE_ENGINE_OVERHEAD_RATIO	"storage.engine.overhead.ratio"
public static final String	STORE_MIGRATION_FABRIC_LIST	"store.migration.fabric.list"
public static final String	STORE_MIGRATION_MAX_RETRY_ATTEMPTS	"store.migration.max.retry.attempts"
public static final String	STORE_MIGRATION_TASK_SCHEDULING_INTERVAL_SECONDS	"store.migration.task.scheduling.interval.seconds"
public static final String	STORE_MIGRATION_THREAD_POOL_SIZE	"store.migration.thread.pool.size"
public static final String	STORE_WRITER_BUFFER_AFTER_LEADER_LOGIC_ENABLED	"store.writer.buffer.after.leader.logic.enabled"
public static final String	STORE_WRITER_BUFFER_MEMORY_CAPACITY	"store.writer.buffer.memory.capacity"
public static final String	STORE_WRITER_BUFFER_NOTIFY_DELTA	"store.writer.buffer.notify.delta"
public static final String	STORE_WRITER_NUMBER	"store.writer.number"
public static final String	STORES_TO_REPLICATE	"stores.to.replicate"
public static final String	SYSTEM_SCHEMA_CLUSTER_NAME	"system.schema.cluster.name"
public static final String	SYSTEM_SCHEMA_INITIALIZATION_AT_START_TIME_ENABLED	"system.schema.initialization.at.start.time.enabled"
public static final String	TERMINAL_STATE_TOPIC_CHECK_DELAY_MS	"controller.terminal.state.topic.check.delay.ms"
public static final String	TIME_LAG_THRESHOLD_FOR_FAST_ONLINE_TRANSITION_IN_RESTART_MINUTES	"time.lag.threshold.for.fast.online.transition.in.restart.minutes"
public static final String	TOPIC_CLEANUP_DELAY_FACTOR	"topic.cleanup.delay.factor"
public static final String	TOPIC_CLEANUP_SLEEP_INTERVAL_BETWEEN_TOPIC_LIST_FETCH_MS	"topic.cleanup.sleep.interval.between.topic.list.fetch.ms"
public static final String	UNREGISTER_METRIC_FOR_DELETED_STORE_ENABLED	"unregister.metric.for.deleted.store.enabled"
public static final String	UNSORTED_INPUT_DRAINER_SIZE	"unsorted.input.drainer.size"
public static final String	USE_DA_VINCI_SPECIFIC_EXECUTION_STATUS_FOR_ERROR	"use.da.vinci.specific.execution.status.for.error"
public static final String	USE_PUSH_STATUS_STORE_FOR_INCREMENTAL_PUSH	"controller.server.incremental.push.use.push.status.store"
public static final String	USE_V2_ADMIN_TOPIC_METADATA	"controller.use.v2.admin.topic.metadata"
public static final String	VALIDATE_VENICE_INTERNAL_SCHEMA_VERSION	"validate.venice.internal.schema.version"
public static final String	VENICE_PARTITIONERS	"venice.partitioners"
public static final String	VENICE_STORAGE_CLUSTER_LEADER_HAAS	"venice.cluster.leader.haas.enabled"
public static final String	WRITER_BATCHING_MAX_BUFFER_SIZE_IN_BYTES	"writer.batching.max.buffer.size.in.bytes"
public static final String	WRITER_BATCHING_MAX_INTERVAL_MS	"writer.batching.max.interval.ms"
public static final String	ZOOKEEPER_ADDRESS	"zookeeper.address"

com.linkedin.venice.HttpConstants

Modifier and Type	Constant Field	Value
public static final String	AVRO_BINARY	"avro/binary"
public static final String	BINARY	"application/octet-stream"
public static final String	HTTP	"http"
public static final String	HTTP_GET	"GET"
public static final String	HTTP_PREFIX	"http://"
public static final String	HTTPS	"https"
public static final String	HTTPS_POST	"POST"
public static final String	HTTPS_PREFIX	"https://"
public static final String	JSON	"application/json"
public static final String	LOCALHOST	"localhost"
public static final int	SC_MISDIRECTED_REQUEST	421
public static final int	SC_SERVICE_OVERLOADED	529
public static final String	TEXT_HTML	"text/html"
public static final String	TEXT_PLAIN	"text/plain"
public static final String	VENICE_ALLOW_REDIRECT	"X-VENICE-ALLOW-REDIRECT"
public static final String	VENICE_API_VERSION	"X-VENICE-API-VERSION"
public static final String	VENICE_CLIENT_COMPUTE	"X-VENICE-CLIENT-COMPUTE"
public static final String	VENICE_CLIENT_COMPUTE_FALSE	"0"
public static final String	VENICE_CLIENT_COMPUTE_TRUE	"1"
public static final String	VENICE_COMPRESSION_STRATEGY	"X-VENICE-COMPRESSION-STRATEGY"
public static final String	VENICE_COMPUTE_VALUE_SCHEMA_ID	"X-VENICE-COMPUTE-VALUE-SCHEMA-ID"
public static final String	VENICE_KEY_COUNT	"X-VENICE-KEY-COUNT"
public static final String	VENICE_REQUEST_RCU	"X-VENICE-RCU"
public static final String	VENICE_RETRY	"X-VENICE-RETRY"
public static final String	VENICE_SCHEMA_ID	"X-VENICE-SCHEMA-ID"
public static final String	VENICE_STORE_VERSION	"X-VENICE-STORE-VERSION"
public static final String	VENICE_STREAMING	"X-VENICE-STREAMING"
public static final String	VENICE_STREAMING_RESPONSE	"X-VENICE-STREAMING-RESPONSE"
public static final String	VENICE_SUPPORTED_COMPRESSION_STRATEGY	"X-VENICE-SUPPORTED-COMPRESSION-STRATEGY"

com.linkedin.venice.LogMessages

Modifier and Type	Constant Field	Value
public static final String	KILLED_JOB_MESSAGE	"Received the signal to kill this consumer. Topic "

com.linkedin.venice.RequestConstants

Modifier and Type	Constant Field	Value
public static final String	B64_FORMAT	"b64"
public static final String	DEFAULT_FORMAT	"string"
public static final String	DELAY_EXECUTION	"delay_execution"
public static final String	FORMAT_KEY	"f"
public static final String	STRING_FORMAT	"string"

com.linkedin.venice.SSLConfig

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_CONTROLLER_SSL_ENABLED	true

com.linkedin.venice.SystemStorePushTask

Modifier and Type	Constant Field	Value
public static final String	TASK_NAME	"PushSystemStore"

com.linkedin.venice.VeniceConstants

Modifier and Type	Constant Field	Value
public static final int	COMPUTE_REQUEST_VERSION_V2	2
public static final int	COMPUTE_REQUEST_VERSION_V3	3
public static final int	COMPUTE_REQUEST_VERSION_V4	4
public static final String	CONTROLLER_SSL_CERTIFICATE_ATTRIBUTE_NAME	"javax.servlet.request.X509Certificate"
public static final int	DEFAULT_PER_ROUTER_READ_QUOTA	20000000
public static final String	DEFAULT_SSL_FACTORY_CLASS_NAME	"com.linkedin.venice.security.DefaultSSLFactory"
public static final String	ENVIRONMENT_CONFIG_KEY_FOR_REGION_NAME	"FABRIC"
public static final String	NATIVE_REPLICATION_DEFAULT_SOURCE_FABRIC	"prod-lva1"
public static final String	SYSTEM_PROPERTY_FOR_APP_RUNNING_REGION	"com.linkedin.app.env"
public static final String	SYSTEM_STORE_OWNER	"venice-internal"
public static final String	TYPE_PUSH_STATUS	"push_status"
public static final String	TYPE_STORE_STATE	"store_state"
public static final String	TYPE_STREAM_HYBRID_STORE_QUOTA	"stream_hybrid_store_quota"
public static final String	TYPE_STREAM_REPROCESSING_HYBRID_STORE_QUOTA	"stream_reprocessing_hybrid_store_quota"
public static final String	VENICE_COMPUTATION_ERROR_MAP_FIELD_NAME	"__veniceComputationError__"

com.linkedin.venice.acl.NoOpDynamicAccessController

Modifier and Type	Constant Field	Value
public static final String	USER_UNKNOWN	"USER_UNKNOWN"

com.linkedin.venice.acl.handler.AbstractStoreAclHandler<REQUEST_TYPE>

Modifier and Type	Constant Field	Value
public static final String	STORE_ACL_CHECK_RESULT	"STORE_ACL_CHECK_RESULT_ATTRIBUTE_KEY"

com.linkedin.venice.client.exceptions.VeniceClientRateExceededException

Modifier and Type	Constant Field	Value
public static final int	HTTP_TOO_MANY_REQUESTS	429

com.linkedin.venice.client.schema.RouterBackedSchemaReader

Modifier and Type	Constant Field	Value
public static final String	TYPE_ALL_VALUE_SCHEMA_IDS	"all_value_schema_ids"
public static final String	TYPE_KEY_SCHEMA	"key_schema"
public static final String	TYPE_UPDATE_SCHEMA	"update_schema"
public static final String	TYPE_VALUE_SCHEMA	"value_schema"

com.linkedin.venice.client.schema.RouterBasedStoreSchemaFetcher

Modifier and Type	Constant Field	Value
public static final String	TYPE_GET_UPDATE_SCHEMA	"update_schema"
public static final String	TYPE_KEY_SCHEMA	"key_schema"
public static final String	TYPE_LATEST_VALUE_SCHEMA	"latest_value_schema"
public static final String	TYPE_VALUE_SCHEMA	"value_schema"

com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder<K>

Modifier and Type	Constant Field	Value
protected static final String	COSINE_SIMILARITY_SPEC	"cosineSimilarity_spec"
protected static final String	DOT_PRODUCT_SPEC	"dotProduct_spec"
protected static final String	HADAMARD_PRODUCT_SPEC	"hadamardProduct_spec"
protected static final String	PROJECTION_SPEC	"projection_spec"

com.linkedin.venice.client.store.AbstractAvroStoreClient<K,V>

Modifier and Type	Constant Field	Value
public static final String	B64_FORMAT	"?f=b64"
public static final String	TYPE_COMPUTE	"compute"
public static final String	TYPE_STORAGE	"storage"

com.linkedin.venice.client.store.ClientConfig<T extends org.apache.avro.specific.SpecificRecord>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME	"venice-discovery"
public static final String	DEFAULT_D2_ZK_BASE_PATH	"/d2"
public static final int	DEFAULT_ZK_TIMEOUT_MS	5000

com.linkedin.venice.client.store.D2ServiceDiscovery

Modifier and Type	Constant Field	Value
public static final String	TYPE_D2_SERVICE_DISCOVERY	"discover_cluster"

com.linkedin.venice.client.store.transport.TransportClient

Modifier and Type	Constant Field	Value
protected static final String	HTTPS	"https"

com.linkedin.venice.common.PushStatusStoreUtils

Modifier and Type	Constant Field	Value
public static final String	CONTROLLER_HEARTBEAT_INSTANCE_NAME	"CONTROLLER_HEARTBEAT"
public static final String	ONGOING_INCREMENTAL_PUSH_STATUSES_KEY	"ONGOING_INCREMENTAL_PUSHES"
public static final String	SERVER_INCREMENTAL_PUSH_PREFIX	"SERVER_SIDE_INCREMENTAL_PUSH_STATUS"

com.linkedin.venice.common.VeniceSystemStoreUtils

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_USER_SYSTEM_STORE_PARTITION_COUNT	1
public static final String	PARENT_CONTROLLER_METADATA_STORE	"parent_controller_metadata_store"
public static final String	PARTICIPANT_STORE	"participant_store"
public static final String	PUSH_JOB_DETAILS_STORE	"push_job_details_store"
public static final String	SEPARATOR	"_"

com.linkedin.venice.compression.VeniceCompressor

Modifier and Type	Constant Field	Value
protected static final int	SCHEMA_HEADER_LENGTH	4

com.linkedin.venice.compute.ComputeRequestWrapper

Modifier and Type	Constant Field	Value
public static final int	LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST	3

com.linkedin.venice.compute.ComputeUtils

Modifier and Type	Constant Field	Value
public static final String	CACHED_SQUARED_L2_NORM_KEY	"CACHED_SQUARED_L2_NORM_KEY"
public static final String	ILLEGAL_AVRO_CHARACTER	"[^A-Za-z0-9_]"
public static final String	ILLEGAL_AVRO_CHARACTER_REPLACEMENT	"_"

com.linkedin.venice.controller.AdminTopicMetadataAccessor

Modifier and Type	Constant Field	Value
public static final String	ADMIN_OPERATION_PROTOCOL_VERSION_KEY	"adminOperationProtocolVersion"
public static final String	EXECUTION_ID_KEY	"executionId"
public static final String	OFFSET_KEY	"offset"
public static final String	POSITION_KEY	"position"
public static final String	UPSTREAM_OFFSET_KEY	"upstreamOffset"
public static final String	UPSTREAM_POSITION_KEY	"upstreamPosition"

com.linkedin.venice.controller.StoreBackupVersionCleanupService

Modifier and Type	Constant Field	Value
public static final String	TYPE_CURRENT_VERSION	"current_version"

com.linkedin.venice.controller.VeniceController

Modifier and Type	Constant Field	Value
public static final String	CONTROLLER_SERVICE_METRIC_PREFIX	"controller"
public static final String	CONTROLLER_SERVICE_NAME	"venice-controller"

com.linkedin.venice.controller.VeniceHelixAdmin

Modifier and Type	Constant Field	Value
protected static final int	INTERNAL_STORE_GET_RRT_TOPIC_ATTEMPTS	3

com.linkedin.venice.controller.grpc.ControllerGrpcConstants

Modifier and Type	Constant Field	Value
public static final String	UNKNOWN_REMOTE_ADDRESS	"unknown"

com.linkedin.venice.controller.kafka.AdminTopicUtils

Modifier and Type	Constant Field	Value
public static final int	ADMIN_TOPIC_PARTITION_ID	0
public static final int	PARTITION_NUM_FOR_ADMIN_TOPIC	1

com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask

Modifier and Type	Constant Field	Value
public static final int	IGNORED_CURRENT_VERSION	-1
public static final int	MAX_RETRIES_FOR_NONEXISTENT_STORE	10

com.linkedin.venice.controller.logcompaction.LogCompactionService

Modifier and Type	Constant Field	Value
public static final int	PRE_EXECUTION_DELAY_MS	0

com.linkedin.venice.controller.migration.MigrationPushStrategyZKAccessor

Modifier and Type	Constant Field	Value
public static final String	MIGRATION_PUSH_STRATEGY_PATH	"/migration-push-strategy"

com.linkedin.venice.controller.server.NotImplemented

Modifier and Type	Constant Field	Value
public static final String	NOT_IMPLEMENTED_MSG	"This method is not implemented yet"

com.linkedin.venice.controller.server.StoreRequestHandler

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_STORE_OWNER	""

com.linkedin.venice.controller.server.VeniceControllerAccessManager

Modifier and Type	Constant Field	Value
protected static final String	UNKNOWN_USER	"USER_UNKNOWN"

com.linkedin.venice.controller.server.VeniceParentControllerRegionStateHandler

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_CHECK_FAILURE_WARN_MESSAGE_PREFIX	"Only active parent controllers are allowed to run "

com.linkedin.venice.controller.server.VeniceRouteHandler<T extends ControllerResponse>

Modifier and Type	Constant Field	Value
public static final String	ACL_CHECK_FAILURE_WARN_MESSAGE_PREFIX	"Only admin users are allowed to run "

com.linkedin.venice.controller.stats.PartitionHealthStats

Modifier and Type	Constant Field	Value
public static final String	UNDER_REPLICATED_PARTITION_SENSOR	"underReplicatedPartition"

com.linkedin.venice.controller.stats.SparkServerStats

Modifier and Type	Constant Field	Value
public static final String	NON_CLUSTER_SPECIFIC_STAT_CLUSTER_NAME	"cluster_generic"

com.linkedin.venice.controller.systemstore.SystemStoreRepairTask

Modifier and Type	Constant Field	Value
public static final String	SYSTEM_STORE_REPAIR_JOB_PREFIX	"CONTROLLER_SYSTEM_STORE_REPAIR_JOB_"

com.linkedin.venice.controllerapi.ControllerApiConstants

Modifier and Type	Constant Field	Value
public static final String	ACCESS_CONTROLLED	"access_controlled"
public static final String	ACCESS_PERMISSION	"access_permission"
public static final String	ACTIVE_ACTIVE_REPLICATION_ENABLED	"active_active_replication_enabled"
public static final String	ADMIN_OPERATION_PROTOCOL_VERSION	"admin_operation_protocol_version"
public static final String	ALLOW_STORE_MIGRATION	"allow.store.migration"
public static final String	AMPLIFICATION_FACTOR	"amplification_factor"
public static final String	AUTO_SCHEMA_REGISTER_FOR_PUSHJOB_ENABLED	"auto_auto_register_for_pushjob_enabled"
public static final String	AUTO_STORE_MIGRATION_ABORT_ON_FAILURE	"auto_store_migration_abort_on_failure"
public static final String	AUTO_STORE_MIGRATION_CURRENT_STEP	"auto_store_migration_current_step"
public static final String	AUTO_STORE_MIGRATION_PAUSE_AFTER_STEP	"auto_store_migration_pause_after_step"
public static final String	BACKUP_STRATEGY	"backup_strategy"
public static final String	BACKUP_VERSION_RETENTION_MS	"backup_version_retention_ms"
public static final String	BATCH_GET_LIMIT	"batch_get_limit"
public static final String	BATCH_GET_ROUTER_CACHE_ENABLED	"batch_get_router_cache_enabled"
public static final String	BATCH_JOB_HEARTBEAT_ENABLED	"batch_job_heartbeat_enabled"
public static final String	BLOB_TRANSFER_ENABLED	"blob_transfer_enabled"
public static final String	BLOB_TRANSFER_IN_SERVER_ENABLED	"blob_transfer_in_server_enabled"
public static final String	BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS	"bootstrap_to_online_timeout_in_hours"
public static final String	BUFFER_REPLAY_POLICY	"buffer_replay_policy"
public static final String	CHILD_CONTROLLER_ADMIN_TOPIC_CONSUMPTION_ENABLED	"child.controller.admin.topic.consumption.enabled"
public static final String	CHUNKING_ENABLED	"chunking_enabled"
public static final String	CLIENT_DECOMPRESSION_ENABLED	"client_decompression_enabled"
public static final String	CLUSTER	"cluster_name"
public static final String	CLUSTER_DEST	"cluster_name_dest"
public static final String	CLUSTER_ID	"cluster_id"
public static final String	COMPACTION_ENABLED	"compaction_enabled"
public static final String	COMPACTION_THRESHOLD_MILLISECONDS	"compaction_threshold_milliseconds"
public static final String	COMPRESSION_DICTIONARY	"compression_dictionary"
public static final String	COMPRESSION_STRATEGY	"compression_strategy"
public static final String	DATA_RECOVERY_COPY_ALL_VERSION_CONFIGS	"data.recovery.copy.all.version.configs"
public static final String	DATA_REPLICATION_POLICY	"data_replication_policy"
public static final String	DEFER_VERSION_SWAP	"defer_version_swap"
public static final String	DERIVED_SCHEMA	"derived_schema"
public static final String	DERIVED_SCHEMA_ID	"derived_schema_id"
public static final String	DEST_FABRIC	"dest_fabric"
public static final String	DISABLE_DAVINCI_PUSH_STATUS_STORE	"disable_davinci_push_status_store"
public static final String	DISABLE_META_STORE	"disable_meta_store"
public static final String	DISABLE_STORE_VIEW	"disable_store_view"
public static final String	ENABLE_DISABLED_REPLICAS	"enable_disabled_replicas"
public static final String	ENABLE_READS	"enable_reads"
public static final String	ENABLE_STORE_MIGRATION	"enable_store_migration"
public static final String	ENABLE_WRITES	"enable_writes"
public static final String	ENUM_SCHEMA_EVOLUTION_ALLOWED	"enum_schema_evolution_allowed"
public static final String	ERROR	"error"
public static final String	ETLED_PROXY_USER_ACCOUNT	"etled_proxy_user_account"
public static final String	EXECUTION_ID	"execution_id"
public static final String	EXPECTED_ROUTER_COUNT	"expected_router_count"
public static final String	FABRIC	"fabric"
public static final String	FABRIC_A	"fabric_a"
public static final String	FABRIC_B	"fabric_b"
public static final String	FROZEN	"frozen"
public static final String	FUTURE_VERSION_ETL_ENABLED	"future_version_etl_enabled"
public static final String	GLOBAL_RT_DIV_ENABLED	"global_rt_div_enabled"
public static final String	HEARTBEAT_TIMESTAMP	"heartbeat_timestamp"
public static final String	HOSTNAME	"hostname"
public static final String	HYBRID_STORE_DISK_QUOTA_ENABLED	"hybrid-store-disk-quota-enabled"
public static final String	HYBRID_STORE_OVERHEAD_BYPASS	"hybrid_store_overhead_bypass"
public static final String	INCLUDE_SYSTEM_STORES	"include_system_stores"
public static final String	INCREMENTAL_PUSH_ENABLED	"incremental_push_enabled"
public static final String	INCREMENTAL_PUSH_VERSION	"incremental_push_version"
public static final String	INSTANCES	"instances"
public static final String	IS_ABORT_MIGRATION_CLEANUP	"is_abort_migration_cleanup"
public static final String	IS_DAVINCI_HEARTBEAT_REPORTED	"is_davinci_heartbeat_reported"
public static final String	IS_SYSTEM_STORE	"is_system_store"
public static final String	IS_WRITE_COMPUTE_ENABLED	"is_write_compute_enabled"
public static final String	KAFKA_TOPIC_LOG_COMPACTION_ENABLED	"kafka.topic.log.compaction.enabled"
public static final String	KAFKA_TOPIC_MIN_IN_SYNC_REPLICA	"kafka.topic.min.in.sync.replica"
public static final String	KAFKA_TOPIC_RETENTION_IN_MS	"kafka.topic.retention.in.ms"
public static final String	KEY_SCHEMA	"key_schema"
public static final String	KEY_URN_COMPRESSION_ENABLED	"key_urn_compression_enabled"
public static final String	KEY_URN_FIELDS	"key_urn_fields"
public static final String	LARGEST_USED_RT_VERSION_NUMBER	"largest_used_rt_version_number"
public static final String	LARGEST_USED_VERSION_NUMBER	"largest_used_version_number"
public static final String	LATEST_SUPERSET_SCHEMA_ID	"latest_superset_schema_id"
public static final String	LOOK_BACK_MS	"look_back_ms"
public static final String	MAX_COMPACTION_LAG_SECONDS	"max_compaction_lag_seconds"
public static final String	MAX_NEARLINE_RECORD_SIZE_BYTES	"max_nearline_record_size_bytes"
public static final String	MAX_RECORD_SIZE_BYTES	"max_record_size_bytes"
public static final String	MIGRATION_DUPLICATE_STORE	"migration_duplicate_store"
public static final String	MIN_COMPACTION_LAG_SECONDS	"min_compaction_lag_seconds"
public static final String	NAME	"store_name"
public static final String	NATIVE_REPLICATION_ENABLED	"native_replication_enabled"
public static final String	NATIVE_REPLICATION_SOURCE_FABRIC	"native_replication_source_fabric"
public static final String	NEARLINE_PRODUCER_COMPRESSION_ENABLED	"nearline_producer_compression_enabled"
public static final String	NEARLINE_PRODUCER_COUNT_PER_WRITER	"nearline_producer_count_per_writer"
public static final String	NUM_VERSIONS_TO_PRESERVE	"num_versions_to_preserve"
public static final String	OFFSET_LAG_TO_GO_ONLINE	"offset_lag_to_go_online"
public static final String	OPERATION	"operation"
public static final String	OWNER	"owner"
public static final String	PARTITION_COUNT	"partition_count"
public static final String	PARTITION_DETAIL_ENABLED	"partition_detail_enabled"
public static final String	PARTITIONER_CLASS	"partitioner_class"
public static final String	PARTITIONER_PARAMS	"partitioner_params"
public static final String	PARTITIONERS	"partitioners"
public static final String	PERSONA_NAME	"persona_name"
public static final String	PERSONA_OWNERS	"persona_owners"
public static final String	PERSONA_QUOTA	"persona_quota"
public static final String	PERSONA_STORES	"persona_stores"
public static final String	POSITION	"position"
public static final String	PUSH_IN_SORTED_ORDER	"push_in_sorted_order"
public static final String	PUSH_JOB_DETAILS	"push_job_details"
public static final String	PUSH_JOB_DURATION	"push_job_duration"
public static final String	PUSH_JOB_ID	"push_job_id"
public static final String	PUSH_JOB_STATUS	"push_job_status"
public static final String	PUSH_STRATEGY	"push_strategy"
public static final String	PUSH_STREAM_SOURCE_ADDRESS	"push_stream_source_address"
public static final String	PUSH_TYPE	"push_type"
public static final String	READ_COMPUTATION_ENABLED	"read_computation_enabled"
public static final String	READ_OPERATION	"read"
public static final String	READ_QUOTA_IN_CU	"read_quota_in_cu"
public static final String	READ_WRITE_OPERATION	"readwrite"
public static final String	REAL_TIME_TOPIC_NAME	"real_time_topic_name"
public static final String	REGIONS_FILTER	"regions_filter"
public static final String	REGULAR_VERSION_ETL_ENABLED	"regular_version_etl_enabled"
public static final String	REMOTE_KAFKA_BOOTSTRAP_SERVERS	"remote_kafka_bootstrap_servers"
public static final String	REPLICATE_ALL_CONFIGS	"replicate_all_configs"
public static final String	REPLICATION_FACTOR	"replication_factor"
public static final String	REPLICATION_METADATA_PROTOCOL_VERSION_ID	"replication_metadata_protocol_version_id"
public static final String	REPLICATION_METADATA_VERSION_ID	"replication_metadata_version_id"
public static final String	REPUSH_SOURCE_VERSION	"repush_source_version"
public static final String	REWIND_TIME_IN_SECONDS	"rewind_time_seconds"
public static final String	REWIND_TIME_IN_SECONDS_OVERRIDE	"rewind_time_in_seconds_override"
public static final String	RMD_CHUNKING_ENABLED	"rmd_chunking_enabled"
public static final String	SCHEMA_COMPAT_TYPE	"schema_compat_type"
public static final String	SCHEMA_ID	"schema_id"
public static final String	SEND_START_OF_PUSH	"start_of_push"
public static final String	SEPARATE_REAL_TIME_TOPIC_ENABLED	"separate_realtime_topic_enabled"
public static final String	SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND	"server.kafka.fetch.quota.records.per.second"
public static final String	SINGLE_GET_ROUTER_CACHE_ENABLED	"single_get_router_cache_enabled"
public static final String	SKIP_DIV	"skip_div"
public static final String	SOURCE_FABRIC	"source_fabric"
public static final String	SOURCE_FABRIC_VERSION_INCLUDED	"source.fabric.version.included"
public static final String	SOURCE_GRID_FABRIC	"source_grid_fabric"
public static final String	SOURCE_REGION	"source_region"
public static final String	STATUS	"status"
public static final String	STORAGE_NODE_ID	"storage_node_id"
public static final String	STORAGE_NODE_READ_QUOTA_ENABLED	"storage_node_read_quota_enabled"
public static final String	STORAGE_QUOTA_IN_BYTE	"storage_quota_in_byte"
public static final String	STORE_CONFIG_NAME_FILTER	"store_config_name_filter"
public static final String	STORE_CONFIG_VALUE_FILTER	"store_config_value_filter"
public static final String	STORE_LIFECYCLE_HOOKS_LIST	"store_lifecycle_hooks_list"
public static final String	STORE_MIGRATION	"store_migration"
public static final String	STORE_NAME	"store_name"
public static final String	STORE_PARTITION	"store_partition"
public static final String	STORE_SIZE	"store_size"
public static final String	STORE_TYPE	"store_type"
public static final String	STORE_VERSION	"store_version"
public static final String	STORE_VIEW	"store_view"
public static final String	STORE_VIEW_CLASS	"store_view_class"
public static final String	STORE_VIEW_NAME	"store_view_name"
public static final String	STORE_VIEW_PARAMS	"store_view_params"
public static final String	STORES_TO_REPLICATE	"stores_to_replicate"
public static final String	TARGET_REGION_PUSH_WITH_DEFERRED_SWAP	"target_region_push_with_deferred_swap"
public static final String	TARGET_SWAP_REGION	"target_swap_region"
public static final String	TARGET_SWAP_REGION_WAIT_TIME	"target_swap_region_wait_time"
public static final String	TARGETED_REGIONS	"targeted_regions"
public static final String	TIME_LAG_TO_GO_ONLINE	"time_lag_to_go_online"
public static final String	TO_BE_STOPPED_INSTANCES	"to_be_stopped_instances"
public static final String	TOPIC	"topic"
public static final String	TOPIC_COMPACTION_POLICY	"topic_compaction_policy"
public static final String	TTL_REPUSH_ENABLED	"ttl_repush_enabled"
public static final String	UNUSED_SCHEMA_DELETION_ENABLED	"unused_schema_deletion_enabled"
public static final String	UPDATED_CONFIGS_LIST	"updated_configs_list"
public static final String	UPSTREAM_POSITION	"upstream_position"
public static final String	VALUE_SCHEMA	"value_schema"
public static final String	VALUE_SCHEMA_IDS	"value_schema_ids"
public static final String	VERSION	"version"
public static final String	VOLDEMORT_STORE_NAME	"voldemort_store_name"
public static final String	WRITE_COMPUTATION_ENABLED	"write_computation_enabled"
public static final String	WRITE_OPERATION	"write"

com.linkedin.venice.controllerapi.D2ServiceDiscoveryResponseV2

Modifier and Type	Constant Field	Value
public static final String	D2_SERVICE_DISCOVERY_RESPONSE_V2_ENABLED	"d2.service.discovery.response.v2.enabled"

com.linkedin.venice.controllerapi.RepushJobResponse

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_EXECUTION_ID	"-1"

com.linkedin.venice.datarecovery.DataRecoveryWorker

Modifier and Type	Constant Field	Value
public static final int	INTERVAL_UNSET	-1

com.linkedin.venice.exceptions.VeniceNoStoreException

Modifier and Type	Constant Field	Value
public static final String	DOES_NOT_EXISTS	" does not exist"

com.linkedin.venice.fastclient.ClientConfig<K,V,T extends org.apache.avro.specific.SpecificRecord>

Modifier and Type	Constant Field	Value
public static final String	LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_BATCH_GET_IN_MILLI_SECONDS	"1-12:8,13-20:30,21-150:50,151-500:100,501-:500"
public static final String	LONG_TAIL_RANGE_BASED_RETRY_THRESHOLD_FOR_COMPUTE_IN_MILLI_SECONDS	"1-12:8,13-20:30,21-150:50,151-500:100,501-:500"

com.linkedin.venice.fastclient.RetriableAvroGenericStoreClient<K,V>

Modifier and Type	Constant Field	Value
public static final String	MULTI_KEY_LONG_TAIL_RETRY_STATS_PREFIX	"multi-key-long-tail-retry-manager-"
public static final String	SINGLE_KEY_LONG_TAIL_RETRY_STATS_PREFIX	"single-key-long-tail-retry-manager-"

com.linkedin.venice.fastclient.meta.RequestBasedMetadata

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT	20L
public static final long	DEFAULT_REFRESH_INTERVAL_IN_SECONDS	60L

com.linkedin.venice.fastclient.transport.HttpClient5BasedR2Client

Modifier and Type	Constant Field	Value
public static final String	HTTP_METHOD_GET_LOWER_CASE	"get"
public static final String	HTTP_METHOD_POST_LOWER_CASE	"post"

com.linkedin.venice.guid.GuidUtils

Modifier and Type	Constant Field	Value
public static final String	GUID_GENERATOR_IMPLEMENTATION	"guid.generator.implementation"

com.linkedin.venice.hadoop.mapreduce.datawriter.jobs.DataWriterMRJob

Modifier and Type	Constant Field	Value
public static final String	HADOOP_PREFIX	"hadoop-conf."

com.linkedin.venice.hadoop.mapreduce.datawriter.partition.VeniceMRPartitioner

Modifier and Type	Constant Field	Value
public static final int	EMPTY_KEY_LENGTH	0

com.linkedin.venice.hadoop.mapreduce.datawriter.reduce.VeniceReducer

Modifier and Type	Constant Field	Value
public static final String	MAP_REDUCE_JOB_ID_PROP	"mapreduce.job.id"

com.linkedin.venice.hadoop.mapreduce.engine.MapReduceEngineTaskConfigProvider

Modifier and Type	Constant Field	Value
public static final String	MAPRED_TASK_ID_PROP_NAME	"mapred.task.id"
public static final String	MAPREDUCE_JOB_NAME_PROP_NAME	"mapreduce.job.name"

com.linkedin.venice.hadoop.ssl.UserCredentialsFactory

Modifier and Type	Constant Field	Value
public static final int	REQUIRED_SECRET_KEY_COUNT	4

com.linkedin.venice.hadoop.task.TaskTracker

Modifier and Type	Constant Field	Value
public static final float	PROGRESS_COMPLETED	1.0f
public static final float	PROGRESS_NOT_SUPPORTED	-1.0f

com.linkedin.venice.hadoop.task.datawriter.AbstractDataWriterTask

Modifier and Type	Constant Field	Value
protected static final int	TASK_ID_NOT_SET	-1

com.linkedin.venice.helix.CachedReadOnlyStoreRepository

Modifier and Type	Constant Field	Value
public static final String	STORE_REPOSITORY_PATH	"/Stores"

com.linkedin.venice.helix.CachedResourceZkStateListener

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_REFRESH_ATTEMPTS_FOR_ZK_RECONNECT	1

com.linkedin.venice.helix.HelixInstanceConfigRepository

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_INSTANCE_GROUP_ID	0

com.linkedin.venice.helix.HelixReadOnlySchemaRepository

Modifier and Type	Constant Field	Value
public static final int	VALUE_SCHEMA_STARTING_ID	1

com.linkedin.venice.helix.HelixSchemaAccessor

Modifier and Type	Constant Field	Value
public static final int	VALUE_SCHEMA_STARTING_ID	1

com.linkedin.venice.helix.HelixState

Modifier and Type	Constant Field	Value
public static final String	DROPPED_STATE	"DROPPED"
public static final String	ERROR_STATE	"ERROR"
public static final String	LEADER_STATE	"LEADER"
public static final String	OFFLINE_STATE	"OFFLINE"
public static final String	STANDBY_STATE	"STANDBY"

com.linkedin.venice.helix.HelixStatusMessageChannel

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_SEND_MESSAGE_TIME_OUT	1000
public static final String	HELIX_MESSAGE_TYPE	"control_message"
public static final String	VENICE_MESSAGE_CLASS	"veniceMessageClass"
public static final String	VENICE_MESSAGE_FIELD	"veniceMessageFields"

com.linkedin.venice.helix.HelixStoreGraveyard

Modifier and Type	Constant Field	Value
public static final String	STORE_GRAVEYARD_PATH	"/StoreGraveyard"
public static final long	STORE_NOT_IN_GRAVEYARD	-1L

com.linkedin.venice.helix.ParentHelixOfflinePushAccessor

Modifier and Type	Constant Field	Value
public static final String	OFFLINE_PUSH_SUB_PATH	"ParentOfflinePushes"

com.linkedin.venice.helix.VeniceOfflinePushMonitorAccessor

Modifier and Type	Constant Field	Value
public static final String	OFFLINE_PUSH_SUB_PATH	"OfflinePushes"

com.linkedin.venice.kafka.protocol.enums.MessageType.Constants

Modifier and Type	Constant Field	Value
public static final byte	CONTROL_MESSAGE_KEY_HEADER_BYTE	0x2
public static final byte	GLOBAL_RT_DIV_KEY_HEADER_BYTE	0x8
public static final byte	PUT_KEY_HEADER_BYTE	0x0
public static final byte	UPDATE_KEY_HEADER_BYTE	0x4

com.linkedin.venice.listener.ReadQuotaEnforcementHandler

Modifier and Type	Constant Field	Value
public static final String	INVALID_REQUEST_RESOURCE_MSG	"Invalid request resource: "
public static final String	SERVER_OVER_CAPACITY_MSG	"Server over capacity"

com.linkedin.venice.listener.ServerAclHandler

Modifier and Type	Constant Field	Value
public static final String	SERVER_ACL_APPROVED	"SERVER_ACL_APPROVED_ATTRIBUTE_KEY"

com.linkedin.venice.listener.ServerLoadControllerHandler

Modifier and Type	Constant Field	Value
public static final String	SERVICE_OVERLOADED_MESSAGE	"Service overloaded, please try again later"

com.linkedin.venice.listener.request.RouterRequest

Modifier and Type	Constant Field	Value
public static final long	NO_REQUEST_TIMEOUT	-1L

com.linkedin.venice.meta.AbstractStore

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_READ_QUOTA	1800L
public static final int	DEFAULT_REPLICATION_FACTOR	3
public static final long	DEFAULT_STORAGE_QUOTA	21474836480L

com.linkedin.venice.meta.HybridStoreConfigImpl

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_HYBRID_OFFSET_LAG_THRESHOLD	1000L
public static final long	DEFAULT_HYBRID_TIME_LAG_THRESHOLD	-1L
public static final String	DEFAULT_REAL_TIME_TOPIC_NAME	""
public static final long	DEFAULT_REWIND_TIME_IN_SECONDS	86400L

com.linkedin.venice.meta.LiveClusterConfig

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_SERVER_KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND	-1

com.linkedin.venice.meta.NameRepository

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAXIMUM_ENTRY_COUNT	2000

com.linkedin.venice.meta.Store

Modifier and Type	Constant Field	Value
public static final int	BOOTSTRAP_TO_ONLINE_TIMEOUT_IN_HOURS	24
public static final int	DEFAULT_BATCH_GET_LIMIT	500
public static final int	IGNORE_VERSION	-1
public static final int	NON_EXISTING_VERSION	0
public static final int	NUM_VERSION_PRESERVE_NOT_SET	0
public static final String	SYSTEM_STORE_FORMAT	"venice_system_store_%s"
public static final String	SYSTEM_STORE_NAME_PREFIX	"venice_system_store_"
public static final long	UNLIMITED_STORAGE_QUOTA	-1L

com.linkedin.venice.meta.Version

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_RT_VERSION_NUMBER	0
public static final String	REAL_TIME_TOPIC_SUFFIX	"_rt"
public static final String	REAL_TIME_TOPIC_TEMPLATE	"%s_rt_v%d"
public static final int	REPLICATION_METADATA_VERSION_ID_UNSET	-1
public static final String	STREAM_REPROCESSING_TOPIC_SUFFIX	"_sr"
public static final String	VENICE_RE_PUSH_PUSH_ID_PREFIX	"venice_re_push_"
public static final String	VENICE_REGULAR_PUSH_WITH_TTL_RE_PUSH_PREFIX	"venice_regular_push_with_ttl_re_push_"
public static final String	VENICE_TTL_RE_PUSH_PUSH_ID_PREFIX	"venice_ttl_re_push_"
public static final String	VERSION_SEPARATOR	"_v"

com.linkedin.venice.offsets.OffsetRecord

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_OFFSET_LAG	-1L
public static final long	LOWEST_OFFSET	-1L
public static final long	LOWEST_OFFSET_LAG	0L
public static final String	NON_AA_REPLICATION_UPSTREAM_OFFSET_MAP_KEY	""

com.linkedin.venice.partitioner.ConstantVenicePartitioner

Modifier and Type	Constant Field	Value
public static final String	CONSTANT_PARTITION	"constant.partition"

com.linkedin.venice.partitioner.DefaultVenicePartitioner

Modifier and Type	Constant Field	Value
public static final String	MD5_HASH_ALGORITHM	"MD5"

com.linkedin.venice.persona.StoragePersonaAccessor

Modifier and Type	Constant Field	Value
public static final String	STORAGE_PERSONA_SUB_PATH	"StoragePersona"

com.linkedin.venice.protocols.CountByValueRequest

Modifier and Type	Constant Field	Value
public static final int	FIELDNAMES_FIELD_NUMBER	4
public static final int	KEYS_FIELD_NUMBER	1
public static final int	RESOURCENAME_FIELD_NUMBER	2
public static final int	TOPK_FIELD_NUMBER	3

com.linkedin.venice.protocols.CountByValueResponse

Modifier and Type	Constant Field	Value
public static final int	ERRORCODE_FIELD_NUMBER	2
public static final int	ERRORMESSAGE_FIELD_NUMBER	3
public static final int	FIELDTOVALUECOUNTS_FIELD_NUMBER	1

com.linkedin.venice.protocols.ValueCount

Modifier and Type	Constant Field	Value
public static final int	VALUETOCOUNTS_FIELD_NUMBER	1

com.linkedin.venice.protocols.VeniceClientRequest

Modifier and Type	Constant Field	Value
public static final int	ISBATCHREQUEST_FIELD_NUMBER	9
public static final int	ISRETRYREQUEST_FIELD_NUMBER	8
public static final int	ISSTREAMINGREQUEST_FIELD_NUMBER	7
public static final int	KEYBYTES_FIELD_NUMBER	3
public static final int	KEYSTRING_FIELD_NUMBER	2
public static final int	METHOD_FIELD_NUMBER	10
public static final int	PARTITION_FIELD_NUMBER	1
public static final int	RESOURCENAME_FIELD_NUMBER	5

com.linkedin.venice.protocols.VeniceReadServiceGrpc

Modifier and Type	Constant Field	Value
public static final String	SERVICE_NAME	"com.linkedin.venice.protocols.VeniceReadService"

com.linkedin.venice.protocols.VeniceServerResponse

Modifier and Type	Constant Field	Value
public static final int	COMPRESSIONSTRATEGY_FIELD_NUMBER	3
public static final int	DATA_FIELD_NUMBER	2
public static final int	ERRORCODE_FIELD_NUMBER	6
public static final int	ERRORMESSAGE_FIELD_NUMBER	7
public static final int	ISSTREAMINGRESPONSE_FIELD_NUMBER	5
public static final int	RESPONSERCU_FIELD_NUMBER	4
public static final int	SCHEMAID_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.AdminCommandExecutionStatusGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	ADMINCOMMANDEXECUTIONID_FIELD_NUMBER	2
public static final int	CLUSTERNAME_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.AdminCommandExecutionStatusGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	ADMINCOMMANDEXECUTIONID_FIELD_NUMBER	2
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	FABRICTOEXECUTIONSTATUSMAP_FIELD_NUMBER	5
public static final int	OPERATION_FIELD_NUMBER	3
public static final int	STARTTIME_FIELD_NUMBER	4

com.linkedin.venice.protocols.controller.AdminTopicGrpcMetadata

Modifier and Type	Constant Field	Value
public static final int	ADMINOPERATIONPROTOCOLVERSION_FIELD_NUMBER	6
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	EXECUTIONID_FIELD_NUMBER	2
public static final int	OFFSET_FIELD_NUMBER	4
public static final int	POSITION_FIELD_NUMBER	7
public static final int	STORENAME_FIELD_NUMBER	3
public static final int	UPSTREAMOFFSET_FIELD_NUMBER	5
public static final int	UPSTREAMPOSITION_FIELD_NUMBER	8

com.linkedin.venice.protocols.controller.AdminTopicMetadataGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	STORENAME_FIELD_NUMBER	2

com.linkedin.venice.protocols.controller.AdminTopicMetadataGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	METADATA_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcServiceGrpc

Modifier and Type	Constant Field	Value
public static final String	SERVICE_NAME	"com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcService"

com.linkedin.venice.protocols.controller.ClusterStoreGrpcInfo

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	STORENAME_FIELD_NUMBER	2

com.linkedin.venice.protocols.controller.ControllerGrpcErrorType

Modifier and Type	Constant Field	Value
public static final int	BAD_REQUEST_VALUE	8
public static final int	CONCURRENT_BATCH_PUSH_VALUE	9
public static final int	CONNECTION_ERROR_VALUE	6
public static final int	GENERAL_ERROR_VALUE	7
public static final int	INCORRECT_CONTROLLER_VALUE	1
public static final int	INVALID_CONFIG_VALUE	3
public static final int	INVALID_SCHEMA_VALUE	2
public static final int	RESOURCE_STILL_EXISTS_VALUE	10
public static final int	SCHEMA_NOT_FOUND_VALUE	5
public static final int	STORE_NOT_FOUND_VALUE	4
public static final int	UNAUTHORIZED_VALUE	11
public static final int	UNKNOWN_VALUE	0

com.linkedin.venice.protocols.controller.CreateStoreGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	ACCESSPERMISSION_FIELD_NUMBER	6
public static final int	ISSYSTEMSTORE_FIELD_NUMBER	5
public static final int	KEYSCHEMA_FIELD_NUMBER	2
public static final int	OWNER_FIELD_NUMBER	4
public static final int	STOREINFO_FIELD_NUMBER	1
public static final int	VALUESCHEMA_FIELD_NUMBER	3

com.linkedin.venice.protocols.controller.CreateStoreGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	OWNER_FIELD_NUMBER	2
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.DeleteAclForStoreGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.DeleteAclForStoreGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.DiscoverClusterGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	STORENAME_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.DiscoverClusterGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	D2SERVICE_FIELD_NUMBER	3
public static final int	PUBSUBBOOTSTRAPSERVERS_FIELD_NUMBER	6
public static final int	SERVERD2SERVICE_FIELD_NUMBER	4
public static final int	STORENAME_FIELD_NUMBER	2
public static final int	ZKADDRESS_FIELD_NUMBER	5

com.linkedin.venice.protocols.controller.GetAclForStoreGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.GetAclForStoreGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	ACCESSPERMISSIONS_FIELD_NUMBER	2
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.LastSuccessfulAdminCommandExecutionGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.LastSuccessfulAdminCommandExecutionGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	LASTSUCCESSFULADMINCOMMANDEXECUTIONID_FIELD_NUMBER	2

com.linkedin.venice.protocols.controller.LeaderControllerGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.LeaderControllerGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	1
public static final int	GRPCURL_FIELD_NUMBER	4
public static final int	HTTPSURL_FIELD_NUMBER	3
public static final int	HTTPURL_FIELD_NUMBER	2
public static final int	SECUREGRPCURL_FIELD_NUMBER	5

com.linkedin.venice.protocols.controller.PubSubPositionGrpcWireFormat

Modifier and Type	Constant Field	Value
public static final int	BASE64POSITIONBYTES_FIELD_NUMBER	2
public static final int	TYPEID_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.ResourceCleanupCheckGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	DESCRIPTION_FIELD_NUMBER	3
public static final int	HASLINGERINGRESOURCES_FIELD_NUMBER	2
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.StoreGrpcServiceGrpc

Modifier and Type	Constant Field	Value
public static final String	SERVICE_NAME	"com.linkedin.venice.protocols.controller.StoreGrpcService"

com.linkedin.venice.protocols.controller.UpdateAclForStoreGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	ACCESSPERMISSIONS_FIELD_NUMBER	3
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.UpdateAclForStoreGrpcResponse

Modifier and Type	Constant Field	Value
public static final int	STOREINFO_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.UpdateAdminOperationProtocolVersionGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	ADMINOPERATIONPROTOCOLVERSION_FIELD_NUMBER	2
public static final int	CLUSTERNAME_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.UpdateAdminTopicMetadataGrpcRequest

Modifier and Type	Constant Field	Value
public static final int	METADATA_FIELD_NUMBER	1

com.linkedin.venice.protocols.controller.VeniceControllerGrpcErrorInfo

Modifier and Type	Constant Field	Value
public static final int	CLUSTERNAME_FIELD_NUMBER	4
public static final int	ERRORMESSAGE_FIELD_NUMBER	2
public static final int	ERRORTYPE_FIELD_NUMBER	3
public static final int	STATUSCODE_FIELD_NUMBER	1
public static final int	STORENAME_FIELD_NUMBER	5

com.linkedin.venice.protocols.controller.VeniceControllerGrpcServiceGrpc

Modifier and Type	Constant Field	Value
public static final String	SERVICE_NAME	"com.linkedin.venice.protocols.controller.VeniceControllerGrpcService"

com.linkedin.venice.protocols.hooks.GrpcStoreLifecycleHookServiceGrpc

Modifier and Type	Constant Field	Value
public static final String	SERVICE_NAME	"com.linkedin.venice.protocols.hooks.GrpcStoreLifecycleHookService"

com.linkedin.venice.protocols.hooks.GrpcStoreLifecycleHooksRequest

Modifier and Type	Constant Field	Value
public static final int	REGION_FIELD_NUMBER	2
public static final int	STORENAME_FIELD_NUMBER	1
public static final int	VERSION_FIELD_NUMBER	3

com.linkedin.venice.protocols.hooks.GrpcStoreLifecycleHooksResponse

Modifier and Type	Constant Field	Value
public static final int	OUTCOME_FIELD_NUMBER	1

com.linkedin.venice.protocols.hooks.StoreVersionLifecycleEventOutcomeProto

Modifier and Type	Constant Field	Value
public static final int	ABORT_VALUE	1
public static final int	PROCEED_VALUE	0
public static final int	ROLLBACK_VALUE	3
public static final int	WAIT_VALUE	2

com.linkedin.venice.pubsub.PubSubConstants

Modifier and Type	Constant Field	Value
public static final long	BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN	172800000L
public static final long	DEFAULT_KAFKA_MIN_LOG_COMPACTION_LAG_MS	86400000L
public static final int	DEFAULT_KAFKA_REPLICATION_FACTOR	3
public static final long	DEFAULT_TOPIC_RETENTION_POLICY_MS	432000000L
public static final long	ETERNAL_TOPIC_RETENTION_POLICY_MS	9223372036854775807L
public static final String	PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS	"pubsub.admin.api.default.timeout.ms"
public static final int	PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE	120000
public static final long	PUBSUB_ADMIN_GET_TOPIC_CONFIG_RETRY_IN_SECONDS_DEFAULT_VALUE	300L
public static final String	PUBSUB_BROKER_ADDRESS	"pubsub.broker.address"
public static final String	PUBSUB_CLIENT_CONFIG_PREFIX	"pubsub."
public static final String	PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS	"pubsub.consumer.api.default.timeout.ms"
public static final int	PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE	60000
public static final String	PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE	"pubsub.consumer.check.topic.existence"
public static final boolean	PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE	false
public static final String	PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS	"pubsub.consumer.poll.retry.backoff.ms"
public static final int	PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE	0
public static final String	PUBSUB_CONSUMER_POLL_RETRY_TIMES	"pubsub.consumer.poll.retry.times"
public static final int	PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE	3
public static final int	PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT	3
public static final String	PUBSUB_CONSUMER_POSITION_RESET_STRATEGY	"pubsub.consumer.position.reset.strategy"
public static final String	PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE	"earliest"
public static final String	PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS	"pubsub.consumer.topic.query.retry.interval.ms"
public static final int	PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE	1000
public static final String	PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES	"pubsub.consumer.topic.query.retry.times"
public static final int	PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE	5
public static final int	PUBSUB_FAST_OPERATION_TIMEOUT_MS	1000
public static final long	PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION	-1L
public static final int	PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE	30000
public static final String	PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS	"pubsub.producer.use.high.throughput.defaults"
public static final int	PUBSUB_TOPIC_DELETE_RETRY_TIMES	3
public static final int	PUBSUB_TOPIC_DELETION_STATUS_POLL_INTERVAL_MS_DEFAULT_VALUE	2000
public static final int	PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE_DEFAULT_VALUE	2
public static final long	PUBSUB_TOPIC_UNKNOWN_RETENTION	-9223372036854775808L

com.linkedin.venice.pubsub.PubSubPositionTypeRegistry

Modifier and Type	Constant Field	Value
public static final int	APACHE_KAFKA_OFFSET_POSITION_TYPE_ID	0
public static final int	EARLIEST_POSITION_RESERVED_TYPE_ID	-2
public static final int	LATEST_POSITION_RESERVED_TYPE_ID	-1
public static final int	POSITION_TYPE_INVALID_MAGIC_VALUE	-2147483648

com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerConfig

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_RECEIVE_BUFFER_SIZE	1048576
public static final String	KAFKA_CLIENT_ID_CONFIG	"kafka.client.id"
public static final String	KAFKA_FETCH_MAX_BYTES_CONFIG	"kafka.fetch.max.bytes"
public static final String	KAFKA_FETCH_MAX_WAIT_MS_CONFIG	"kafka.fetch.max.wait.ms"
public static final String	KAFKA_FETCH_MIN_BYTES_CONFIG	"kafka.fetch.min.bytes"
public static final String	KAFKA_GROUP_ID_CONFIG	"kafka.group.id"
public static final String	KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG	"kafka.max.partition.fetch.bytes"
public static final String	KAFKA_MAX_POLL_RECORDS_CONFIG	"kafka.max.poll.records"

com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerConfig

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_KAFKA_BATCH_SIZE	"524288"
public static final String	DEFAULT_KAFKA_LINGER_MS	"1000"
public static final String	KAFKA_BOOTSTRAP_SERVERS	"kafka.bootstrap.servers"
public static final String	KAFKA_BUFFER_MEMORY	"kafka.buffer.memory"
public static final String	KAFKA_CLIENT_ID	"kafka.client.id"
public static final String	KAFKA_CONFIG_PREFIX	"kafka."
public static final String	KAFKA_LINGER_MS	"kafka.linger.ms"
public static final String	KAFKA_OVER_SSL	"kafka.over.ssl"
public static final String	KAFKA_PRODUCER_DELIVERY_TIMEOUT_MS	"kafka.delivery.timeout.ms"
public static final String	KAFKA_PRODUCER_REQUEST_TIMEOUT_MS	"kafka.request.timeout.ms"
public static final String	KAFKA_PRODUCER_RETRIES_CONFIG	"kafka.retries"
public static final String	PUBSUB_KAFKA_CLIENT_CONFIG_PREFIX	"pubsub.kafka."
public static final String	SSL_KAFKA_BOOTSTRAP_SERVERS	"ssl.kafka.bootstrap.servers"
public static final String	SSL_TO_KAFKA_LEGACY	"ssl.to.kakfa"

com.linkedin.venice.pubsub.api.PubSubMessageHeaders

Modifier and Type	Constant Field	Value
public static final String	EXECUTION_ID_KEY	"EXECUTION_ID"
public static final String	VENICE_LEADER_COMPLETION_STATE_HEADER	"lcs"
public static final String	VENICE_TRANSPORT_PROTOCOL_HEADER	"vtp"
public static final String	VENICE_VIEW_PARTITIONS_MAP_HEADER	"vpm"

com.linkedin.venice.pubsub.api.PubSubTopicType

Modifier and Type	Constant Field	Value
public static final String	ADMIN_TOPIC_PREFIX	"venice_admin_"

com.linkedin.venice.pubsub.mock.InMemoryPubSubPosition

Modifier and Type	Constant Field	Value
public static final int	INMEMORY_PUBSUB_POSITION_TYPE_ID	-42

com.linkedin.venice.pushmonitor.AbstractPushMonitor

Modifier and Type	Constant Field	Value
public static final int	MAX_PUSH_TO_KEEP	5

com.linkedin.venice.pushmonitor.OfflinePushStatus

Modifier and Type	Constant Field	Value
public static final String	HELIX_ASSIGNMENT_COMPLETED	"Helix assignment complete"
public static final String	HELIX_RESOURCE_NOT_CREATED	"Helix Resource not created."

com.linkedin.venice.pushmonitor.ReplicaStatus

Modifier and Type	Constant Field	Value
public static final int	MAX_HISTORY_LENGTH	50
public static final long	NO_PROGRESS	-1L

com.linkedin.venice.response.VeniceReadResponseStatus

Modifier and Type	Constant Field	Value
public static final int	BAD_REQUEST	400
public static final int	INTERNAL_ERROR	500
public static final int	KEY_NOT_FOUND	-420
public static final int	OK	200
public static final int	SERVICE_UNAVAILABLE	503
public static final int	TOO_MANY_REQUESTS	429

com.linkedin.venice.router.AdminOperationsHandler

Modifier and Type	Constant Field	Value
public static final String	EARLY_THROTTLE_ENABLED	"earlyThrottleEnabled"
public static final String	READ_THROTTLING_ENABLED	"readThrottlingEnabled"

com.linkedin.venice.router.InFlightRequestStat

Modifier and Type	Constant Field	Value
public static final String	TOTAL_INFLIGHT_REQUEST_COUNT	"total_inflight_request_count"

com.linkedin.venice.router.RouterServer

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CLUSTER_DISCOVERY_D2_SERVICE_NAME	"venice-discovery"
public static final String	ROUTER_SERVICE_METRIC_PREFIX	"router"
public static final String	ROUTER_SERVICE_NAME	"venice-router"

com.linkedin.venice.router.api.VenicePathParser

Modifier and Type	Constant Field	Value
public static final String	ACTION_DISABLE	"disable"
public static final String	ACTION_ENABLE	"enable"
public static final String	SEP	"/"
public static final int	STORE_MAX_LENGTH	128
public static final String	TASK_READ_QUOTA_THROTTLE	"readQuotaThrottle"
public static final String	TYPE_COMPUTE	"compute"
public static final String	TYPE_STORAGE	"storage"

com.linkedin.venice.router.api.routing.helix.HelixGroupLeastLoadedStrategy

Modifier and Type	Constant Field	Value
public static final int	MAX_ALLOWED_GROUP	100

com.linkedin.venice.samza.VeniceSystemFactory

Modifier and Type	Constant Field	Value
public static final String	DEPLOYMENT_ID	"deployment.id"
public static final String	DOT	"."
public static final String	LEGACY_CHILD_D2_ZK_HOSTS_PROPERTY	"__r2d2DefaultClient__.r2d2Client.zkHosts"
public static final String	LEGACY_VENICE_CHILD_CONTROLLER_D2_SERVICE	"VeniceController"
public static final String	LEGACY_VENICE_PARENT_CONTROLLER_D2_SERVICE	"VeniceParentController"
public static final String	SYSTEMS_PREFIX	"systems."
public static final String	VENICE_AGGREGATE	"aggregate"
public static final String	VENICE_CHILD_CONTROLLER_D2_SERVICE	"venice.child.controller.d2.service"
public static final String	VENICE_CHILD_D2_ZK_HOSTS	"venice.child.d2.zk.hosts"
public static final String	VENICE_CONTROLLER_DISCOVERY_URL	"venice.controller.discovery.url"
public static final String	VENICE_PARENT_CONTROLLER_D2_SERVICE	"venice.parent.controller.d2.service"
public static final String	VENICE_PARENT_D2_ZK_HOSTS	"venice.parent.d2.zk.hosts"
public static final String	VENICE_PUSH_TYPE	"push.type"
public static final String	VENICE_ROUTER_URL	"venice.router.url"
public static final String	VENICE_STORE	"store"

com.linkedin.venice.schema.SchemaData

Modifier and Type	Constant Field	Value
public static final int	DUPLICATE_VALUE_SCHEMA_CODE	-2
public static final int	INVALID_VALUE_SCHEMA_ID	-1
public static final int	UNKNOWN_SCHEMA_ID	0

com.linkedin.venice.schema.avro.SchemaCompatibility

Modifier and Type	Constant Field	Value
public static final String	READER_WRITER_COMPATIBLE_MESSAGE	"Reader schema can always successfully decode data written using the writer schema."

com.linkedin.venice.schema.avro.SchemaCompatibility19

Modifier and Type	Constant Field	Value
public static final String	READER_WRITER_COMPATIBLE_MESSAGE	"Reader schema can always successfully decode data written using the writer schema."

com.linkedin.venice.schema.rmd.RmdConstants

Modifier and Type	Constant Field	Value
public static final String	REPLICATION_CHECKPOINT_VECTOR_FIELD_NAME	"replication_checkpoint_vector"
public static final int	REPLICATION_CHECKPOINT_VECTOR_FIELD_POS	1
public static final String	TIMESTAMP_FIELD_NAME	"timestamp"
public static final int	TIMESTAMP_FIELD_POS	0

com.linkedin.venice.schema.rmd.v1.CollectionRmdTimestamp<DELETED_ELEMENT_TYPE>

Modifier and Type	Constant Field	Value
public static final String	ACTIVE_ELEM_TS_FIELD_NAME	"activeElementsTimestamps"
public static final int	ACTIVE_ELEM_TS_FIELD_POS	3
public static final String	DELETED_ELEM_FIELD_NAME	"deletedElementsIdentities"
public static final int	DELETED_ELEM_FIELD_POS	4
public static final String	DELETED_ELEM_TS_FIELD_NAME	"deletedElementsTimestamps"
public static final int	DELETED_ELEM_TS_FIELD_POS	5
public static final String	PUT_ONLY_PART_LENGTH_FIELD_NAME	"putOnlyPartLength"
public static final int	PUT_ONLY_PART_LENGTH_FIELD_POS	2
public static final String	TOP_LEVEL_COLO_ID_FIELD_NAME	"topLevelColoID"
public static final int	TOP_LEVEL_COLO_ID_FIELD_POS	1
public static final String	TOP_LEVEL_TS_FIELD_NAME	"topLevelFieldTimestamp"
public static final int	TOP_LEVEL_TS_FIELD_POS	0

com.linkedin.venice.schema.rmd.v1.RmdSchemaGeneratorV1

Modifier and Type	Constant Field	Value
protected static final String	METADATA_RECORD_SUFFIX	"MetadataRecord"
protected static final String	NAME_SPACE	"com.linkedin.venice"

com.linkedin.venice.schema.vson.VsonAvroSchemaAdapter

Modifier and Type	Constant Field	Value
public static final String	BYTE_WRAPPER	"byteWrapper"
public static final String	SHORT_WRAPPER	"shortWrapper"

com.linkedin.venice.schema.writecompute.WriteComputeConstants

Modifier and Type	Constant Field	Value
public static final String	LIST_OPS_NAME	"ListOps"
public static final String	MAP_DIFF	"mapDiff"
public static final String	MAP_OPS_NAME	"MapOps"
public static final String	MAP_UNION	"mapUnion"
public static final String	SET_DIFF	"setDiff"
public static final String	SET_UNION	"setUnion"
public static final String	WRITE_COMPUTE_RECORD_SCHEMA_SUFFIX	"WriteOpRecord"

com.linkedin.venice.serialization.KeyWithChunkingSuffixSerializer

Modifier and Type	Constant Field	Value
public static final String	IGNORED_TOPIC_NAME	"ignored"

com.linkedin.venice.serialization.avro.InternalAvroSpecificSerializer<SPECIFIC_RECORD extends org.apache.avro.specific.SpecificRecord>

Modifier and Type	Constant Field	Value
public static final int	MAX_ATTEMPTS_FOR_SCHEMA_READER	60
public static final int	SENTINEL_PROTOCOL_VERSION_USED_FOR_UNDETECTABLE_COMPILED_SCHEMA	-1
public static final int	SENTINEL_PROTOCOL_VERSION_USED_FOR_UNVERSIONED_PROTOCOL	0
public static final String	VENICE_SCHEMA_READER_CONFIG	"venice.schema-reader"
public static final int	WAIT_TIME_BETWEEN_SCHEMA_READER_ATTEMPTS_IN_MS	1000

com.linkedin.venice.spark.SparkConstants

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_SPARK_CLUSTER	"local[*]"
public static final String	KEY_COLUMN_NAME	"key"
public static final String	PARTITION_COLUMN_NAME	"__partition__"
public static final String	RMD_COLUMN_NAME	"rmd"
public static final String	SPARK_APP_NAME_CONFIG	"spark.app.name"
public static final String	SPARK_CASE_SENSITIVE_CONFIG	"spark.sql.caseSensitive"
public static final String	SPARK_CLUSTER_CONFIG	"venice.spark.cluster"
public static final String	SPARK_DATA_WRITER_CONF_PREFIX	"spark.data.writer.conf."
public static final String	SPARK_LEADER_CONFIG	"spark.master"
public static final String	SPARK_SESSION_CONF_PREFIX	"venice.spark.session.conf."
public static final String	VALUE_COLUMN_NAME	"value"

com.linkedin.venice.stats.AbstractVeniceAggStats<T extends AbstractVeniceStats>

Modifier and Type	Constant Field	Value
public static final String	STORE_NAME_FOR_TOTAL_STAT	"total"

com.linkedin.venice.stats.AbstractVeniceStats

Modifier and Type	Constant Field	Value
public static final String	DELIMITER	"--"

com.linkedin.venice.stats.LongAdderRateGauge

Modifier and Type	Constant Field	Value
public static final int	RATE_GAUGE_CACHE_DURATION_IN_SECONDS	30

com.linkedin.venice.stats.ServerConnectionStats

Modifier and Type	Constant Field	Value
public static final String	CLIENT_CONNECTION_COUNT_GAUGE	"client_connection_count"
public static final String	CLIENT_CONNECTION_REQUEST	"client_connection_request"
public static final String	ROUTER_CONNECTION_COUNT_GAUGE	"router_connection_count"
public static final String	ROUTER_CONNECTION_REQUEST	"router_connection_request"

com.linkedin.venice.stats.VeniceMetricsConfig

Modifier and Type	Constant Field	Value
public static final String	OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION	"otel.exporter.otlp.metrics.default.histogram.aggregation"
public static final String	OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION_MAX_BUCKETS	"otel.exporter.otlp.metrics.default.histogram.aggregation.max.buckets"
public static final String	OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION_MAX_SCALE	"otel.exporter.otlp.metrics.default.histogram.aggregation.max.scale"
public static final String	OTEL_EXPORTER_OTLP_METRICS_ENDPOINT	"otel.exporter.otlp.metrics.endpoint"
public static final String	OTEL_EXPORTER_OTLP_METRICS_HEADERS	"otel.exporter.otlp.metrics.headers"
public static final String	OTEL_EXPORTER_OTLP_METRICS_PROTOCOL	"otel.exporter.otlp.metrics.protocol"
public static final String	OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE	"otel.exporter.otlp.metrics.temporality.preference"
public static final String	OTEL_VENICE_EXPORT_LAST_RECORDED_VALUE_FOR_SYNCHRONOUS_GAUGE	"otel.venice.export.last.recorded.value.for.synchronous.gauge"
public static final String	OTEL_VENICE_METRICS_CUSTOM_DESCRIPTION_FOR_HISTOGRAM	"otel.venice.metrics.custom.description.for.histogram"
public static final String	OTEL_VENICE_METRICS_CUSTOM_DIMENSIONS_MAP	"otel.venice.metrics.custom.dimensions.map"
public static final String	OTEL_VENICE_METRICS_ENABLED	"otel.venice.metrics.enabled"
public static final String	OTEL_VENICE_METRICS_EXPORT_INTERVAL_IN_SECONDS	"otel.venice.metrics.export.interval.in.seconds"
public static final String	OTEL_VENICE_METRICS_EXPORT_TO_ENDPOINT	"otel.venice.metrics.export.to.endpoint"
public static final String	OTEL_VENICE_METRICS_EXPORT_TO_LOG	"otel.venice.metrics.export.to.log"
public static final String	OTEL_VENICE_METRICS_NAMING_FORMAT	"otel.venice.metrics.naming.format"
public static final String	OTEL_VENICE_METRICS_PREFIX	"otel.venice.metrics.prefix"
public static final String	OTEL_VENICE_USE_OPENTELEMETRY_INITIALIZED_BY_APPLICATION	"otel.venice.use.opentelemetry.initialized.by.application"
public static final String	TEHUTI_VENICE_METRICS_ENABLED	"tehuti.venice.metrics.enabled"

com.linkedin.venice.stats.VeniceOpenTelemetryMetricsRepository

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_METRIC_PREFIX	"venice."

com.linkedin.venice.store.rocksdb.RocksDBUtils

Modifier and Type	Constant Field	Value
public static final double	ROCKSDB_OVERHEAD_RATIO_FOR_HYBRID_STORE	2.11

com.linkedin.venice.streaming.StreamingConstants

Modifier and Type	Constant Field	Value
public static final int	KEY_ID_FOR_STREAMING_FOOTER	-1000000
public static final int	NON_EXISTING_KEY_SCHEMA_ID	-1000
public static final int	STREAMING_FOOTER_SCHEMA_ID	-1001

com.linkedin.venice.system.store.ControllerClientBackedSystemSchemaInitializer

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_KEY_SCHEMA_STR	"\"int\""

com.linkedin.venice.system.store.MetaStoreWriter

Modifier and Type	Constant Field	Value
public static final String	KEY_STRING_CLUSTER_NAME	"KEY_CLUSTER_NAME"
public static final String	KEY_STRING_PARTITION_ID	"KEY_PARTITION_ID"
public static final String	KEY_STRING_SCHEMA_ID	"KEY_SCHEMA_ID"
public static final String	KEY_STRING_STORE_NAME	"KEY_STORE_NAME"
public static final String	KEY_STRING_VERSION_NUMBER	"KEY_VERSION_NUMBER"

com.linkedin.venice.utils.ByteUtils

Modifier and Type	Constant Field	Value
public static final long	BYTES_PER_GB	1073741824L
public static final int	BYTES_PER_KB	1024
public static final int	BYTES_PER_MB	1048576
public static final int	SIZE_OF_BOOLEAN	1
public static final int	SIZE_OF_INT	4
public static final int	SIZE_OF_LONG	8
public static final int	SIZE_OF_SHORT	2

com.linkedin.venice.utils.ChunkingTestUtils

Modifier and Type	Constant Field	Value
public static final int	CHUNK_LENGTH	10

com.linkedin.venice.utils.HelixUtils

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_HELIX_OP_RETRY_COUNT	9

com.linkedin.venice.utils.LogContext

Modifier and Type	Constant Field	Value
public static final String	LOG_CONTEXT_KEY	"logContext"

com.linkedin.venice.utils.PathResourceRegistry<T>

Modifier and Type	Constant Field	Value
public static final String	WILDCARD_MATCH_ANY	"*"

com.linkedin.venice.utils.RedundantExceptionFilter

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BITSET_SIZE	134217728

com.linkedin.venice.utils.SslUtils

Modifier and Type	Constant Field	Value
public static final String	LOCAL_KEYSTORE_JKS	"localhost.jks"
public static final String	LOCAL_PASSWORD	"dev_pass"

com.linkedin.venice.utils.TestStoragePersonaUtils

Modifier and Type	Constant Field	Value
public static final String	OWNERS_DOES_NOT_EXIST_REGEX	"Invalid owner\\(s\\) provided"
public static final String	PERSONA_DOES_NOT_EXIST_REGEX	"Update failed: persona with name .* does not exist in this cluster"
public static final String	QUOTA_FAILED_REGEX	"Invalid persona quota:.*"
public static final String	STORES_FAILED_REGEX	"Invalid store\\(s\\) provided: .*"

com.linkedin.venice.utils.TestWriteUtils

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_USER_DATA_RECORD_COUNT	100
public static final String	DEFAULT_USER_DATA_VALUE_PREFIX	"test_name_"

com.linkedin.venice.utils.Time

Modifier and Type	Constant Field	Value
public static final int	HOURS_PER_DAY	24
public static final int	MINUTES_PER_HOUR	60
public static final int	MS_PER_DAY	86400000
public static final int	MS_PER_HOUR	3600000
public static final int	MS_PER_MINUTE	60000
public static final int	MS_PER_SECOND	1000
public static final int	NS_PER_MS	1000000
public static final int	NS_PER_SECOND	1000000000
public static final int	NS_PER_US	1000
public static final int	SECONDS_PER_DAY	86400
public static final int	SECONDS_PER_HOUR	3600
public static final int	SECONDS_PER_MINUTE	60
public static final int	US_PER_MS	1000
public static final int	US_PER_SECOND	1000000

com.linkedin.venice.utils.Utils

Modifier and Type	Constant Field	Value
public static final String	FATAL_DATA_VALIDATION_ERROR	"fatal data validation problem"
public static final String	SEPARATE_TOPIC_SUFFIX	"_sep"
public static final String	WILDCARD_MATCH_ANY	"*"

com.linkedin.venice.views.ChangeCaptureView

Modifier and Type	Constant Field	Value
public static final String	CHANGE_CAPTURE_TOPIC_SUFFIX	"_cc"
public static final String	CHANGE_CAPTURE_VIEW_WRITER_CLASS_NAME	"com.linkedin.davinci.store.view.ChangeCaptureViewWriter"

com.linkedin.venice.views.MaterializedView

Modifier and Type	Constant Field	Value
public static final String	MATERIALIZED_VIEW_TOPIC_SUFFIX	"_mv"
public static final String	MATERIALIZED_VIEW_WRITER_CLASS_NAME	"com.linkedin.davinci.store.view.MaterializedViewWriter"

com.linkedin.venice.views.VeniceView

Modifier and Type	Constant Field	Value
public static final String	VIEW_NAME_SEPARATOR	"_"
public static final String	VIEW_STORE_PREFIX	"view_store_"

com.linkedin.venice.views.ViewUtils

Modifier and Type	Constant Field	Value
public static final String	ETERNAL_TOPIC_RETENTION_ENABLED	"eternal.topic.retention.enabled"
public static final String	LOG_COMPACTION_ENABLED	"log.compaction.enabled"
public static final String	NEARLINE_PRODUCER_COMPRESSION_ENABLED	"nearline.producer.compression.enabled"
public static final String	NEARLINE_PRODUCER_COUNT_PER_WRITER	"nearline.producer.count.per.writer"
public static final String	PARTITION_COUNT	"sub.partition.count"
public static final String	USE_FAST_KAFKA_OPERATION_TIMEOUT	"use.fast.kafka.operation.timeout"

com.linkedin.venice.vpj.VenicePushJobConstants

Modifier and Type	Constant Field	Value
public static final String	ALLOW_DUPLICATE_KEY	"allow.duplicate.key"
public static final String	ALLOW_REGULAR_PUSH_WITH_TTL_REPUSH	"allow.regular.push.with.ttl.repush"
public static final String	BATCH_NUM_BYTES_PROP	"batch.num.bytes"
public static final String	COMPRESSION_DICTIONARY_SAMPLE_SIZE	"compression.dictionary.sample.size"
public static final String	COMPRESSION_DICTIONARY_SIZE_LIMIT	"compression.dictionary.size.limit"
public static final String	COMPRESSION_METRIC_COLLECTION_ENABLED	"compression.metric.collection.enabled"
public static final String	COMPRESSION_STRATEGY	"compression.strategy"
public static final String	CONTROLLER_REQUEST_RETRY_ATTEMPTS	"controller.request.retry.attempts"
public static final String	D2_ZK_HOSTS_PREFIX	"d2.zk.hosts."
public static final String	DATA_WRITER_COMPUTE_JOB_CLASS	"data.writer.compute.job.class"
public static final int	DEFAULT_BATCH_BYTES_SIZE	1000000
public static final int	DEFAULT_COMPRESSION_DICTIONARY_SAMPLE_SIZE	209715200
public static final boolean	DEFAULT_COMPRESSION_METRIC_COLLECTION_ENABLED	false
public static final boolean	DEFAULT_EXTENDED_SCHEMA_VALIDITY_CHECK_ENABLED	true
public static final boolean	DEFAULT_IS_DUPLICATED_KEY_ALLOWED	false
public static final long	DEFAULT_JOB_STATUS_IN_UNKNOWN_STATE_TIMEOUT_MS	1800000L
public static final String	DEFAULT_KEY_FIELD_PROP	"key"
public static final int	DEFAULT_MAX_SPLITS_PER_PARTITION	5
public static final long	DEFAULT_POLL_STATUS_INTERVAL_MS	300000L
public static final long	DEFAULT_PUBSUB_INPUT_MAX_RECORDS_PER_MAPPER	5000000L
public static final boolean	DEFAULT_PUBSUB_INPUT_SECONDARY_COMPARATOR_USE_LOCAL_LOGICAL_INDEX	false
public static final long	DEFAULT_RE_PUSH_REWIND_IN_SECONDS_OVERRIDE	86400L
public static final String	DEFAULT_RMD_FIELD_PROP	"rmd"
public static final boolean	DEFAULT_SSL_ENABLED	false
public static final String	DEFAULT_VALUE_FIELD_PROP	"value"
public static final String	DEFER_VERSION_SWAP	"defer.version.swap"
public static final String	DERIVED_SCHEMA_ID_PROP	"derived.schema.id"
public static final String	ENABLE_SSL	"venice.ssl.enable"
public static final String	ENABLE_WRITE_COMPUTE	"venice.write.compute.enable"
public static final String	ETL_VALUE_SCHEMA_TRANSFORMATION	"etl.value.schema.transformation"
public static final String	EXTENDED_SCHEMA_VALIDITY_CHECK_ENABLED	"extended.schema.validity.check.enabled"
public static final String	FILE_KEY_SCHEMA	"key.schema"
public static final String	FILE_VALUE_SCHEMA	"value.schema"
public static final String	GENERATE_PARTIAL_UPDATE_RECORD_FROM_INPUT	"generate.partial.update.record.from.input"
public static final String	GLOB_FILTER_PATTERN	"[^_.]*"
public static final String	HADOOP_TMP_DIR	"hadoop.tmp.dir"
public static final String	HADOOP_VALIDATE_SCHEMA_AND_BUILD_DICT_PREFIX	"hadoop-dict-build-conf."
public static final String	HYBRID_BATCH_WRITE_OPTIMIZATION_ENABLED	"hybrid.batch.write.optimization.enabled"
public static final String	INCREMENTAL_PUSH	"incremental.push"
public static final String	INPUT_PATH_LAST_MODIFIED_TIME	"input.path.last.modified.time"
public static final String	INPUT_PATH_PROP	"input.path"
public static final String	JOB_EXEC_ID	"job.execution.id"
public static final String	JOB_EXEC_URL	"job.execution.url"
public static final String	JOB_SERVER_NAME	"job.server.name"
public static final String	JOB_STATUS_IN_UNKNOWN_STATE_TIMEOUT_MS	"job.status.in.unknown.state.timeout.ms"
public static final String	KAFKA_INPUT_BROKER_URL	"kafka.input.broker.url"
public static final String	KAFKA_INPUT_COMBINER_ENABLED	"kafka.input.combiner.enabled"
public static final String	KAFKA_INPUT_COMPRESSION_BUILD_NEW_DICT_ENABLED	"kafka.input.compression.build.new.dict.enabled"
public static final String	KAFKA_INPUT_FABRIC	"kafka.input.fabric"
public static final String	KAFKA_INPUT_MAX_RECORDS_PER_MAPPER	"kafka.input.max.records.per.mapper"
public static final String	KAFKA_INPUT_SOURCE_COMPRESSION_STRATEGY	"kafka.input.source.compression.strategy"
public static final String	KAFKA_INPUT_SOURCE_TOPIC_CHUNKING_ENABLED	"kafka.input.source.topic.chunking.enabled"
public static final String	KAFKA_INPUT_TOPIC	"kafka.input.topic"
public static final String	KAFKA_SOURCE_KEY_SCHEMA_STRING_PROP	"kafka.source.key.schema"
public static final String	KEY_FIELD_PROP	"key.field"
public static final String	KEY_INPUT_FILE_DATA_SIZE	"inputFileDataSize"
public static final String	KEY_ZSTD_COMPRESSION_DICTIONARY	"zstdDictionary"
public static final String	KIF_RECORD_READER_KAFKA_CONFIG_PREFIX	"kif.record.reader.kafka."
public static final String	LEGACY_AVRO_KEY_FIELD_PROP	"avro.key.field"
public static final String	LEGACY_AVRO_VALUE_FIELD_PROP	"avro.value.field"
public static final String	MAP_REDUCE_PARTITIONER_CLASS_CONFIG	"map.reduce.partitioner.class"
public static final int	MINIMUM_NUMBER_OF_SAMPLES_REQUIRED_TO_BUILD_ZSTD_DICTIONARY	20
public static final String	NEWER_KME_SCHEMAS_PREFIX	"newer.kme.schemas.prefix."
public static final String	NON_CRITICAL_EXCEPTION	"This exception does not fail the push job. "
public static final int	NOT_SET	-1
public static final String	PARENT_CONTROLLER_REGION_NAME	"parent.controller.region.name"
public static final String	PARTITION_COUNT	"partition.count"
public static final String	POLL_JOB_STATUS_INTERVAL_MS	"poll.job.status.interval.ms"
public static final String	POLL_STATUS_RETRY_ATTEMPTS	"poll.status.retry.attempts"
public static final String	PUBSUB_INPUT_MAX_SPLITS_PER_PARTITION	"pubsub.input.max.splits.per.partition"
public static final String	PUBSUB_INPUT_SECONDARY_COMPARATOR_USE_LOCAL_LOGICAL_INDEX	"pubsub.input.secondary.comparator.use.local.logical.index"
public static final String	PUBSUB_INPUT_SPLIT_STRATEGY	"pubsub.input.split.strategy"
public static final String	PUBSUB_INPUT_SPLIT_TIME_WINDOW_IN_MINUTES	"pubsub.input.split.time.window.in.minutes"
public static final String	PUSH_JOB_TIMEOUT_OVERRIDE_MS	"push.job.timeout.override.ms"
public static final String	PUSH_TO_SEPARATE_REALTIME_TOPIC	"push.to.separate.realtime.topic"
public static final String	REDUCER_SPECULATIVE_EXECUTION_ENABLE	"reducer.speculative.execution.enable"
public static final String	REPUSH_TTL_ENABLE	"repush.ttl.enable"
public static final String	REPUSH_TTL_POLICY	"repush.ttl.policy"
public static final String	REPUSH_TTL_SECONDS	"repush.ttl.seconds"
public static final String	REPUSH_TTL_START_TIMESTAMP	"repush.ttl.start.timestamp"
public static final String	REWIND_EPOCH_TIME_BUFFER_IN_SECONDS_OVERRIDE	"rewind.epoch.time.buffer.in.seconds.override"
public static final String	REWIND_EPOCH_TIME_IN_SECONDS_OVERRIDE	"rewind.epoch.time.in.seconds.override"
public static final String	REWIND_TIME_IN_SECONDS_OVERRIDE	"rewind.time.in.seconds.override"
public static final String	RMD_FIELD_PROP	"timestamp.field"
public static final String	RMD_SCHEMA_DIR	"rmd.schema.dir"
public static final String	RMD_SCHEMA_ID_PROP	"rmd.schema.id"
public static final String	RMD_SCHEMA_PROP	"rmd.schema"
public static final String	SCHEMA_STRING_PROP	"schema"
public static final String	SEND_CONTROL_MESSAGES_DIRECTLY	"send.control.messages.directly"
public static final String	SOURCE_ETL	"source.etl"
public static final String	SOURCE_GRID_FABRIC	"source.grid.fabric"
public static final String	SOURCE_KAFKA	"source.kafka"
public static final String	SPARK_NATIVE_INPUT_FORMAT_ENABLED	"spark.native.input.format.enabled"
public static final String	SSL_CONFIGURATOR_CLASS_CONFIG	"ssl.configurator.class"
public static final String	SSL_KEY_PASSWORD_PROPERTY_NAME	"ssl.key.password.property.name"
public static final String	SSL_KEY_STORE_PASSWORD_PROPERTY_NAME	"ssl.key.store.password.property.name"
public static final String	SSL_KEY_STORE_PROPERTY_NAME	"ssl.key.store.property.name"
public static final String	SSL_PREFIX	"ssl"
public static final String	SSL_TRUST_STORE_PROPERTY_NAME	"ssl.trust.store.property.name"
public static final String	STORAGE_ENGINE_OVERHEAD_RATIO	"storage_engine_overhead_ratio"
public static final String	STORAGE_QUOTA_PROP	"storage.quota"
public static final String	SUPPRESS_END_OF_PUSH_MESSAGE	"suppress.end.of.push.message"
public static final String	SYSTEM_SCHEMA_READER_ENABLED	"system.schema.reader.enabled"
public static final String	TARGETED_REGION_PUSH_ENABLED	"targeted.region.push.enabled"
public static final String	TARGETED_REGION_PUSH_LIST	"targeted.region.push.list"
public static final String	TARGETED_REGION_PUSH_WITH_DEFERRED_SWAP	"targeted.region.push.with.deferred.swap"
public static final String	TARGETED_REGION_PUSH_WITH_DEFERRED_SWAP_WAIT_TIME_MINUTES	"targeted.region.push.with.deferred.swap.wait.time.minutes"
public static final String	TELEMETRY_MESSAGE_INTERVAL	"telemetry.message.interval"
public static final String	TEMP_DIR_PREFIX	"tmp.dir.prefix"
public static final String	TOPIC_PROP	"venice.kafka.topic"
public static final int	UNCREATED_VERSION_NUMBER	-1
public static final String	UPDATE_SCHEMA_STRING_PROP	"update.schema"
public static final String	VALUE_FIELD_PROP	"value.field"
public static final String	VALUE_SCHEMA_DIR	"value.schema.dir"
public static final String	VALUE_SCHEMA_ID_PROP	"value.schema.id"
public static final String	VENICE_DISCOVER_URL_PROP	"venice.discover.urls"
public static final String	VENICE_STORE_NAME_PROP	"venice.store.name"
public static final String	VSON_PUSH	"vson.push"
public static final String	ZSTD_COMPRESSION_LEVEL	"zstd.compression.level"
public static final String	ZSTD_DICTIONARY_CREATION_REQUIRED	"zstd.dictionary.creation.required"
public static final String	ZSTD_DICTIONARY_CREATION_SUCCESS	"zstd.dictionary.creation.success"

com.linkedin.venice.vpj.pubsub.input.PubSubSplitIterator

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_EMPTY_RESULT_RETRIES	12

com.linkedin.venice.vpj.pubsub.input.SplitRequest

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_SPLITS	5
public static final long	DEFAULT_RECORDS_PER_SPLIT	5000000L

com.linkedin.venice.writer.VeniceWriter<K,V,U>

Modifier and Type	Constant Field	Value
public static final long	APP_DEFAULT_LOGICAL_TS	-2L
public static final String	CHECK_SUM_TYPE	"venice.writer.checksum.type"
public static final String	CLOSE_TIMEOUT_MS	"venice.writer.close.timeout.ms"
public static final int	DEFAULT_CLOSE_TIMEOUT_MS	30000
public static final int	DEFAULT_MAX_ATTEMPTS_WHEN_TOPIC_MISSING	30
public static final int	DEFAULT_MAX_SIZE_FOR_USER_PAYLOAD_PER_MESSAGE_IN_BYTES	972800
public static final String	ENABLE_CHUNKING	"venice.writer.chunking.enabled"
public static final String	ENABLE_RMD_CHUNKING	"venice.writer.replication.metadata.chunking.enabled"
public static final String	ENABLE_UNCOMPRESSED_RECORD_SIZE_LIMIT	"venice.writer.enable.uncompressed.record.size.limit"
public static final String	MAX_ATTEMPTS_WHEN_TOPIC_MISSING	"venice.writer.max.attemps.when.topic.missing"
public static final String	MAX_ELAPSED_TIME_FOR_SEGMENT_IN_MS	"venice.writer.max.elapsed.time.for.segment.in.ms"
public static final String	MAX_RECORD_SIZE_BYTES	"venice.writer.max.record.size.bytes"
public static final String	MAX_SIZE_FOR_USER_PAYLOAD_PER_MESSAGE_IN_BYTES	"venice.writer.max.size.for.user.payload.per.message.in.bytes"
public static final String	PRODUCER_QUEUE_SIZE	"venice.writer.producer.queue.size"
public static final String	PRODUCER_THREAD_COUNT	"venice.writer.producer.thread.count"
public static final int	UNLIMITED_MAX_RECORD_SIZE	-1
public static final long	VENICE_DEFAULT_LOGICAL_TS	-1L
public static final int	VENICE_DEFAULT_TIMESTAMP_METADATA_VERSION_ID	-1
public static final int	VENICE_DEFAULT_VALUE_SCHEMA_ID	-1
public static final String	VENICE_WRITER_CONFIG_PREFIX	"venice.writer."

com.linkedin.venice.zk.VeniceZkPaths

Modifier and Type	Constant Field	Value
public static final String	ADMIN_TOPIC_METADATA	"adminTopicMetadata"
public static final String	ADMIN_TOPIC_METADATA_V2	"adminTopicMetadataV2"
public static final String	CLUSTER_CONFIG	"ClusterConfig"
public static final String	DARK_CLUSTER_CONFIG	"DarkClusterConfig"
public static final String	EXECUTION_IDS	"executionids"
public static final String	OFFLINE_PUSHES	"OfflinePushes"
public static final String	PARENT_OFFLINE_PUSHES	"ParentOfflinePushes"
public static final String	ROUTERS	"routers"
public static final String	STORE_CONFIGS	"storeConfigs"
public static final String	STORE_GRAVEYARD	"StoreGraveyard"
public static final String	STORES	"Stores"