public static final String |
ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG |
"anomaly.detection.allow.capacity.estimation" |
public static final String |
ANOMALY_DETECTION_GOALS_CONFIG |
"anomaly.detection.goals" |
public static final String |
ANOMALY_DETECTION_INTERVAL_MS_CONFIG |
"anomaly.detection.interval.ms" |
public static final String |
ANOMALY_NOTIFIER_CLASS_CONFIG |
"anomaly.notifier.class" |
public static final String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final String |
BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG |
"broker.capacity.config.resolver.class" |
public static final String |
BROKER_FAILURE_ALERT_THRESHOLD_MS_CONFIG |
"broker.failure.alert.threshold.ms" |
public static final 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 String |
BROKER_FAILURE_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG |
"broker.failure.exclude.recently.demoted.brokers" |
public static final String |
BROKER_FAILURE_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG |
"broker.failure.exclude.recently.removed.brokers" |
public static final String |
BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS_CONFIG |
"broker.failure.self.healing.threshold.ms" |
public static final 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 String |
BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"broker.metric.sample.aggregator.completeness.cache.size" |
public static final String |
BROKER_METRICS_WINDOW_MS_CONFIG |
"broker.metrics.window.ms" |
public static final String |
BROKER_REMOVAL_SHUTDOWN_MS_CONFIG |
"broker.removal.shutdown.timeout.ms" |
public static final String |
CALCULATED_THROTTLE_RATIO_CONFIG |
"calculated.throttle.ratio" |
public static final String |
CLIENT_ID_CONFIG |
"client.id" |
public static final String |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final String |
CPU_BALANCE_THRESHOLD_CONFIG |
"cpu.balance.threshold" |
public static final String |
CPU_CAPACITY_THRESHOLD_CONFIG |
"cpu.capacity.threshold" |
public static final String |
CPU_LOW_UTILIZATION_THRESHOLD_CONFIG |
"cpu.low.utilization.threshold" |
public static final String |
DEFAULT_API_TIMEOUT_MS_CONFIG |
"default.api.timeout.ms" |
public static final int |
DEFAULT_API_TIMEOUT_MS_DEFAULT |
60000 |
public static final String |
DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"default.replica.movement.strategies" |
public static final String |
DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG |
"demotion.history.retention.time.ms" |
public static final String |
DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.cluster.response.timeout.ms" |
public static final String |
DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.topics.response.timeout.ms" |
public static final String |
DISK_BALANCE_THRESHOLD_CONFIG |
"disk.balance.threshold" |
public static final String |
DISK_CAPACITY_THRESHOLD_CONFIG |
"disk.max.load" |
public static final String |
DISK_LOW_UTILIZATION_THRESHOLD_CONFIG |
"disk.low.utilization.threshold" |
public static final String |
DISK_READ_RATIO_CONFIG |
"disk.read.ratio" |
public static final String |
EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG |
"execution.progress.check.interval.ms" |
public static final String |
EXECUTOR_NOTIFIER_CLASS_CONFIG |
"executor.notifier.class" |
public static final String |
FOLLOWER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"follower.network.inbound.weight.for.cpu.util" |
public static final String |
GOAL_BALANCEDNESS_PRIORITY_WEIGHT_CONFIG |
"goal.balancedness.priority.weight" |
public static final String |
GOAL_BALANCEDNESS_STRICTNESS_WEIGHT_CONFIG |
"goal.balancedness.strictness.weight" |
public static final String |
GOAL_VIOLATION_DELAY_ON_NEW_BROKER_MS_CONFIG |
"goal.violation.delay.on.new.brokers.ms" |
public static final String |
GOAL_VIOLATION_DELAY_ON_NEW_BROKER_MS_DOC |
"Amount of time (in ms) to delay self-healing when new brokers join the cluster. Allows the cluster to stabilize." |
public static final String |
GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG |
"goal.violation.distribution.threshold.multiplier" |
public static final String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG |
"goal.violation.exclude.recently.demoted.brokers" |
public static final String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG |
"goal.violation.exclude.recently.removed.brokers" |
public static final String |
GOALS_CONFIG |
"goals" |
public static final String |
INTRA_BROKER_GOALS_CONFIG |
"intra.broker.goals" |
public static final String |
INVALID_REPLICA_ASSIGNMENT_RETRY_INTERVAL_MS_DOC |
"The time, in milliseconds, after which proposal execution will give up on retrying failures due to an invalid replica assignment on the same proposal. Retrying is useful to guard against edge cases like a broker being restarting during plan execution, at which point any reassignment containing that broker can result in an exception." |
public static final String |
INVALID_REPLICA_ASSIGNMENT_RETRY_TIMEOUT_MS_CONFIG |
"invalid.replica.assignment.retry.timeout.ms" |
public static final String |
LEADER_ACTION_TIMEOUT_MS_CONFIG |
"executor.leader.action.timeout.ms" |
public static final String |
LEADER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"leader.network.inbound.weight.for.cpu.util" |
public static final String |
LEADER_NETWORK_OUTBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG |
"leader.network.outbound.weight.for.cpu.util" |
public static final String |
LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"leader.replica.count.balance.threshold" |
public static final String |
LINEAR_REGRESSION_MODEL_CPU_UTIL_BUCKET_SIZE_CONFIG |
"linear.regression.model.cpu.util.bucket.size" |
public static final String |
LINEAR_REGRESSION_MODEL_MIN_NUM_CPU_UTIL_BUCKETS_CONFIG |
"linear.regression.model.min.num.cpu.util.buckets" |
public static final String |
LINEAR_REGRESSION_MODEL_REQUIRED_SAMPLES_PER_CPU_UTIL_BUCKET_CONFIG |
"linear.regression.model.required.samples.per.bucket" |
public static final String |
LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG |
"logdir.response.timeout.ms" |
public static final String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG |
"max.allowed.extrapolations.per.broker" |
public static final String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG |
"max.allowed.extrapolations.per.partition" |
public static final String |
MAX_REPLICAS_PER_BROKER_CONFIG |
"max.replicas" |
public static final String |
MAX_VOLUME_THROUGHPUT_MB_CONFIG |
"max.volume.throughput.mb" |
public static final String |
METADATA_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final String |
METADATA_TTL_CONFIG |
"metadata.ttl" |
public static final String |
METRIC_SAMPLER_CLASS_CONFIG |
"metric.sampler.class" |
public static final String |
METRIC_SAMPLER_PARTITION_ASSIGNOR_CLASS_CONFIG |
"metric.sampler.partition.assignor.class" |
public static final String |
METRIC_SAMPLING_INTERVAL_MS_CONFIG |
"metric.sampling.interval.ms" |
public static final String |
MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG |
"min.samples.per.broker.metrics.window" |
public static final String |
MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG |
"min.samples.per.partition.metrics.window" |
public static final String |
MIN_VALID_PARTITION_RATIO_CONFIG |
"min.valid.partition.ratio" |
public static final String |
NETWORK_IN_CAPACITY_BYTES_CONFIG |
"network.in.max.bytes.per.second" |
public static final String |
NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG |
"network.inbound.balance.threshold" |
public static final String |
NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.inbound.capacity.threshold" |
public static final String |
NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.inbound.low.utilization.threshold" |
public static final String |
NETWORK_OUT_CAPACITY_BYTES_CONFIG |
"network.out.max.bytes.per.second" |
public static final String |
NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG |
"network.outbound.balance.threshold" |
public static final String |
NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.outbound.capacity.threshold" |
public static final String |
NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.outbound.low.utilization.threshold" |
public static final String |
NUM_BROKER_METRICS_WINDOWS_CONFIG |
"num.broker.metrics.windows" |
public static final String |
NUM_CACHED_RECENT_ANOMALY_STATES_CONFIG |
"num.cached.recent.anomaly.states" |
public static final 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 String |
NUM_CONCURRENT_INTRA_BROKER_PARTITION_MOVEMENTS_CONFIG |
"num.concurrent.intra.broker.partition.movements" |
public static final String |
NUM_CONCURRENT_LEADER_MOVEMENTS_CONFIG |
"num.concurrent.leader.movements" |
public static final String |
NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER_CONFIG |
"num.concurrent.partition.movements.per.broker" |
public static final String |
NUM_METRIC_FETCHERS_CONFIG |
"num.metric.fetchers" |
public static final String |
NUM_PARTITION_METRICS_WINDOWS_CONFIG |
"num.partition.metrics.windows" |
public static final String |
OVERRIDE_STATIC_THROTTLES_CONFIG |
"static.throttle.rate.override.enabled" |
public static final String |
PARTITION_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"partition.metric.sample.aggregator.completeness.cache.size" |
public static final String |
PARTITION_METRICS_WINDOW_MS_CONFIG |
"partition.metrics.window.ms" |
public static final 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 String |
PLAN_COMPUTATION_RETRY_TIMEOUT_MS_CONFIG |
"plan.computation.retry.timeout.ms" |
public static final String |
READ_THROUGHPUT_MULTIPLIER_CONFIG |
"read.throughput.multiplier" |
public static final String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final String |
REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG |
"removal.history.retention.time.ms" |
public static final String |
REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"replica.count.balance.threshold" |
public static final String |
REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"replica.movement.strategies" |
public static final String |
REPLICATION_THROTTLE_CONFIG |
"throttle.bytes.per.second" |
public static final String |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.ms" |
public static final String |
SAMPLE_STORE_CLASS_CONFIG |
"sample.store.class" |
public static final String |
SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG |
"sampling.allow.cpu.capacity.estimation" |
public static final String |
SELF_HEALING_BROKER_FAILURE_ENABLED_CONFIG |
"self.healing.broker.failure.enabled" |
public static final String |
SELF_HEALING_BROKER_FAILURE_ENABLED_DOC |
"Enable self healing for broker failure detector." |
public static final String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_CONFIG |
"self.healing.goal.violation.enabled" |
public static final String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_DOC |
"Enable self healing for goal violation detector." |
public static final String |
SELF_HEALING_GOALS_CONFIG |
"self.healing.goals" |
public static final String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final String |
TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"topic.replica.count.balance.threshold" |
public static final String |
TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG |
"topics.excluded.from.partition.movement" |
public static final String |
USE_LINEAR_REGRESSION_MODEL_CONFIG |
"use.linear.regression.model" |
public static final String |
WRITE_THROUGHPUT_MULTIPLIER_CONFIG |
"write.throughput.multiplier" |
public static final String |
ZOOKEEPER_CONNECT_CONFIG |
"zookeeper.connect" |
public static final String |
ZOOKEEPER_SECURITY_ENABLED_CONFIG |
"zookeeper.security.enabled" |