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_METRIC_SAMPLE_STORE_TOPIC_CONFIG |
"broker.metric.sample.store.topic" |
public static final String |
BROKER_METRIC_SAMPLE_STORE_TOPIC_DOC |
"Topic where broker metric samples are stored." |
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 |
BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_CONFIG |
"broker.replica.exclusion.timeout.ms" |
public static final String |
BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_DOC |
"Timeout in ms for the controller to respond to a broker exclusion request" |
public static final String |
BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG |
"broker.sample.store.topic.partition.count" |
public static final String |
BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT_DOC |
"Number of partitions to use for the broker sample store topic" |
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_BROKER_SAMPLE_STORE_TOPIC |
"_confluent_balancer_broker_samples" |
public static final int |
DEFAULT_BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT |
32 |
public static final long |
DEFAULT_MAX_SAMPLE_LOAD_TIME_MS_CONFIG |
30000L |
public static final long |
DEFAULT_MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS |
3600000L |
public static final long |
DEFAULT_MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS |
3600000L |
public static final int |
DEFAULT_NUM_SAMPLE_LOADING_THREADS |
2 |
public static final String |
DEFAULT_PARTITION_SAMPLE_STORE_TOPIC |
"_confluent_balancer_partition_samples" |
public static final int |
DEFAULT_PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT |
32 |
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_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_CONFIG |
"describe.broker.exclusion.timeout.ms" |
public static final String |
DESCRIBE_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_DOC |
"Timeout in ms for the controller to respond to a describe broker exclusions request" |
public static final String |
DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.cluster.response.timeout.ms" |
public static final String |
DESCRIBE_CONFIGS_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.configs.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_SAMPLE_LOAD_TIME_MS_CONFIG |
"sample.load.time.max.ms" |
public static final String |
MAX_SAMPLE_LOAD_TIME_MS_DOC |
"Maximum time to use for loading metric samples; sample store loads taking longer than this will be aborted." |
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_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG |
"min.broker.sample.store.topic.retention.time.ms" |
public static final String |
MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_DOC |
"How long to retain data in the broker sample store topic" |
public static final String |
MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG |
"min.partition.sample.store.topic.retention.time.ms" |
public static final String |
MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_DOC |
"How long to retain data in the partition sample store topic" |
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 |
NUM_SAMPLE_LOADING_THREADS_CONFIG |
"num.sample.loading.threads" |
public static final String |
NUM_SAMPLE_LOADING_THREADS_DOC |
"Number of threads to use for initial loading of samples on startup" |
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_METRIC_SAMPLE_STORE_TOPIC_CONFIG |
"partition.metric.sample.store.topic" |
public static final String |
PARTITION_METRIC_SAMPLE_STORE_TOPIC_DOC |
"Topic where partition metric samples are stored." |
public static final String |
PARTITION_METRICS_WINDOW_MS_CONFIG |
"partition.metrics.window.ms" |
public static final String |
PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG |
"partition.sample.store.topic.partition.count" |
public static final String |
PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT_DOC |
"Number of partitions to use for the partition sample store topic." |
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" |