public static final java.lang.String |
ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG |
"anomaly.detection.allow.capacity.estimation" |
public static final java.lang.String |
ANOMALY_DETECTION_GOALS_CONFIG |
"anomaly.detection.goals" |
public static final java.lang.String |
ANOMALY_DETECTION_INTERVAL_MS_CONFIG |
"anomaly.detection.interval.ms" |
public static final java.lang.String |
ANOMALY_NOTIFIER_CLASS_CONFIG |
"anomaly.notifier.class" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG |
"broker.capacity.config.resolver.class" |
public static final java.lang.String |
BROKER_FAILURE_ALERT_THRESHOLD_MS_CONFIG |
"broker.failure.alert.threshold.ms" |
public static final java.lang.String |
BROKER_FAILURE_ALERT_THRESHOLD_MS_DOC |
"Grace period in milliseconds for a failed broker to rejoin the cluster before firing an alert" |
public static final java.lang.String |
BROKER_FAILURE_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG |
"broker.failure.exclude.recently.demoted.brokers" |
public static final java.lang.String |
BROKER_FAILURE_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG |
"broker.failure.exclude.recently.removed.brokers" |
public static final java.lang.String |
BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS_CONFIG |
"broker.failure.self.healing.threshold.ms" |
public static final java.lang.String |
BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS_DOC |
"Grace period in milliseconds for a failed broker to rejoin the cluster before triggering a self-healing action. Must not be less than \'broker.failure.alert.threshold.ms\'" |
public static final java.lang.String |
BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"broker.metric.sample.aggregator.completeness.cache.size" |
public static final java.lang.String |
BROKER_METRICS_WINDOW_MS_CONFIG |
"broker.metrics.window.ms" |
public static final java.lang.String |
BROKER_REMOVAL_SHUTDOWN_MS_CONFIG |
"broker.removal.shutdown.timeout.ms" |
public static final java.lang.String |
CALCULATED_THROTTLE_RATIO_CONFIG |
"calculated.throttle.ratio" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final java.lang.String |
CPU_BALANCE_THRESHOLD_CONFIG |
"cpu.balance.threshold" |
public static final java.lang.String |
CPU_CAPACITY_THRESHOLD_CONFIG |
"cpu.capacity.threshold" |
public static final java.lang.String |
CPU_LOW_UTILIZATION_THRESHOLD_CONFIG |
"cpu.low.utilization.threshold" |
public static final java.lang.String |
DEFAULT_API_TIMEOUT_MS_CONFIG |
"default.api.timeout.ms" |
public static final int |
DEFAULT_API_TIMEOUT_MS_DEFAULT |
60000 |
public static final java.lang.String |
DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"default.replica.movement.strategies" |
public static final java.lang.String |
DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG |
"demotion.history.retention.time.ms" |
public static final java.lang.String |
DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.cluster.response.timeout.ms" |
public static final java.lang.String |
DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.topics.response.timeout.ms" |
public static final java.lang.String |
DISK_BALANCE_THRESHOLD_CONFIG |
"disk.balance.threshold" |
public static final java.lang.String |
DISK_CAPACITY_THRESHOLD_CONFIG |
"disk.max.load" |
public static final java.lang.String |
DISK_LOW_UTILIZATION_THRESHOLD_CONFIG |
"disk.low.utilization.threshold" |
public static final java.lang.String |
DISK_READ_RATIO_CONFIG |
"disk.read.ratio" |
public static final java.lang.String |
EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG |
"execution.progress.check.interval.ms" |
public static final java.lang.String |
EXECUTOR_NOTIFIER_CLASS_CONFIG |
"executor.notifier.class" |
public static final java.lang.String |
FOLLOWER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"follower.network.inbound.weight.for.cpu.util" |
public static final java.lang.String |
GOAL_BALANCEDNESS_PRIORITY_WEIGHT_CONFIG |
"goal.balancedness.priority.weight" |
public static final java.lang.String |
GOAL_BALANCEDNESS_STRICTNESS_WEIGHT_CONFIG |
"goal.balancedness.strictness.weight" |
public static final java.lang.String |
GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG |
"goal.violation.distribution.threshold.multiplier" |
public static final java.lang.String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG |
"goal.violation.exclude.recently.demoted.brokers" |
public static final java.lang.String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG |
"goal.violation.exclude.recently.removed.brokers" |
public static final java.lang.String |
GOALS_CONFIG |
"goals" |
public static final java.lang.String |
INTRA_BROKER_GOALS_CONFIG |
"intra.broker.goals" |
public static final java.lang.String |
LEADER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"leader.network.inbound.weight.for.cpu.util" |
public static final java.lang.String |
LEADER_NETWORK_OUTBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"leader.network.outbound.weight.for.cpu.util" |
public static final java.lang.String |
LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"leader.replica.count.balance.threshold" |
public static final java.lang.String |
LINEAR_REGRESSION_MODEL_CPU_UTIL_BUCKET_SIZE_CONFIG |
"linear.regression.model.cpu.util.bucket.size" |
public static final java.lang.String |
LINEAR_REGRESSION_MODEL_MIN_NUM_CPU_UTIL_BUCKETS_CONFIG |
"linear.regression.model.min.num.cpu.util.buckets" |
public static final java.lang.String |
LINEAR_REGRESSION_MODEL_REQUIRED_SAMPLES_PER_CPU_UTIL_BUCKET_CONFIG |
"linear.regression.model.required.samples.per.bucket" |
public static final java.lang.String |
LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG |
"logdir.response.timeout.ms" |
public static final java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG |
"max.allowed.extrapolations.per.broker" |
public static final java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG |
"max.allowed.extrapolations.per.partition" |
public static final java.lang.String |
MAX_REPLICAS_PER_BROKER_CONFIG |
"max.replicas" |
public static final java.lang.String |
MAX_VOLUME_THROUGHPUT_MB_CONFIG |
"max.volume.throughput.mb" |
public static final java.lang.String |
METADATA_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final java.lang.String |
METADATA_TTL_CONFIG |
"metadata.ttl" |
public static final java.lang.String |
METRIC_SAMPLER_CLASS_CONFIG |
"metric.sampler.class" |
public static final java.lang.String |
METRIC_SAMPLER_PARTITION_ASSIGNOR_CLASS_CONFIG |
"metric.sampler.partition.assignor.class" |
public static final java.lang.String |
METRIC_SAMPLING_INTERVAL_MS_CONFIG |
"metric.sampling.interval.ms" |
public static final java.lang.String |
MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG |
"min.samples.per.broker.metrics.window" |
public static final java.lang.String |
MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG |
"min.samples.per.partition.metrics.window" |
public static final java.lang.String |
MIN_VALID_PARTITION_RATIO_CONFIG |
"min.valid.partition.ratio" |
public static final java.lang.String |
NETWORK_IN_CAPACITY_BYTES_CONFIG |
"network.in.max.bytes.per.second" |
public static final java.lang.String |
NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG |
"network.inbound.balance.threshold" |
public static final java.lang.String |
NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.inbound.capacity.threshold" |
public static final java.lang.String |
NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.inbound.low.utilization.threshold" |
public static final java.lang.String |
NETWORK_OUT_CAPACITY_BYTES_CONFIG |
"network.out.max.bytes.per.second" |
public static final java.lang.String |
NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG |
"network.outbound.balance.threshold" |
public static final java.lang.String |
NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.outbound.capacity.threshold" |
public static final java.lang.String |
NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.outbound.low.utilization.threshold" |
public static final java.lang.String |
NUM_BROKER_METRICS_WINDOWS_CONFIG |
"num.broker.metrics.windows" |
public static final java.lang.String |
NUM_CACHED_RECENT_ANOMALY_STATES_CONFIG |
"num.cached.recent.anomaly.states" |
public static final java.lang.String |
NUM_CACHED_RECENT_ANOMALY_STATES_DOC |
"The number of recent anomaly states cached for different anomaly types presented via the anomaly substate response of the state endpoint." |
public static final java.lang.String |
NUM_CONCURRENT_INTRA_BROKER_PARTITION_MOVEMENTS_CONFIG |
"num.concurrent.intra.broker.partition.movements" |
public static final java.lang.String |
NUM_CONCURRENT_LEADER_MOVEMENTS_CONFIG |
"num.concurrent.leader.movements" |
public static final java.lang.String |
NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER_CONFIG |
"num.concurrent.partition.movements.per.broker" |
public static final java.lang.String |
NUM_METRIC_FETCHERS_CONFIG |
"num.metric.fetchers" |
public static final java.lang.String |
NUM_PARTITION_METRICS_WINDOWS_CONFIG |
"num.partition.metrics.windows" |
public static final java.lang.String |
OVERRIDE_STATIC_THROTTLES_CONFIG |
"static.throttle.rate.override.enabled" |
public static final java.lang.String |
PARTITION_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"partition.metric.sample.aggregator.completeness.cache.size" |
public static final java.lang.String |
PARTITION_METRICS_WINDOW_MS_CONFIG |
"partition.metrics.window.ms" |
public static final java.lang.String |
PLAN_COMPUTATION_RETRY_INTERVAL_MS_DOC |
"The time, in milliseconds, after which plan computation will give up on retrying failures due to insufficient metrics. Note that this only applies to the plan computation used for broker removal and broker addition operations." |
public static final java.lang.String |
PLAN_COMPUTATION_RETRY_TIMEOUT_MS_CONFIG |
"plan.computation.retry.timeout.ms" |
public static final java.lang.String |
READ_THROUGHPUT_MULTIPLIER_CONFIG |
"read.throughput.multiplier" |
public static final java.lang.String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG |
"removal.history.retention.time.ms" |
public static final java.lang.String |
REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"replica.count.balance.threshold" |
public static final java.lang.String |
REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"replica.movement.strategies" |
public static final java.lang.String |
REPLICATION_THROTTLE_CONFIG |
"throttle.bytes.per.second" |
public static final java.lang.String |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.ms" |
public static final java.lang.String |
SAMPLE_STORE_CLASS_CONFIG |
"sample.store.class" |
public static final java.lang.String |
SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG |
"sampling.allow.cpu.capacity.estimation" |
public static final java.lang.String |
SELF_HEALING_BROKER_FAILURE_ENABLED_CONFIG |
"self.healing.broker.failure.enabled" |
public static final java.lang.String |
SELF_HEALING_BROKER_FAILURE_ENABLED_DOC |
"Enable self healing for broker failure detector." |
public static final java.lang.String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_CONFIG |
"self.healing.goal.violation.enabled" |
public static final java.lang.String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_DOC |
"Enable self healing for goal violation detector." |
public static final java.lang.String |
SELF_HEALING_GOALS_CONFIG |
"self.healing.goals" |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"topic.replica.count.balance.threshold" |
public static final java.lang.String |
TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG |
"topics.excluded.from.partition.movement" |
public static final java.lang.String |
USE_LINEAR_REGRESSION_MODEL_CONFIG |
"use.linear.regression.model" |
public static final java.lang.String |
WRITE_THROUGHPUT_MULTIPLIER_CONFIG |
"write.throughput.multiplier" |
public static final java.lang.String |
ZOOKEEPER_CONNECT_CONFIG |
"zookeeper.connect" |
public static final java.lang.String |
ZOOKEEPER_SECURITY_ENABLED_CONFIG |
"zookeeper.security.enabled" |