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 |
CC_STARTUP_RETRY_DELAY_MINUTES_CONFIG |
"startup.retry.delay.minutes" |
public static final String |
CC_STARTUP_RETRY_DURATION_HOURS_CONFIG |
"startup.retry.max.hours" |
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 |
CPU_UTILIZATION_DETECTOR_DURATION_MS_CONFIG |
"cpu.utilization.detector.duration.ms" |
public static final String |
CPU_UTILIZATION_DETECTOR_OVERUTILIZATION_THRESHOLD_CONFIG |
"cpu.utilization.detector.overutilization.threshold" |
public static final String |
CPU_UTILIZATION_DETECTOR_UNDERUTILIZATION_THRESHOLD_CONFIG |
"cpu.utilization.detector.underutilization.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 int |
DEFAULT_RESOURCE_UTILIZATION_DETECTOR_INTERVAL_MS |
60000 |
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_BATCH_SIZE_CONFIG |
"describe.configs.batch.size" |
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 |
EXECUTOR_REFRESH_TIME_MS_CONFIG |
"executor.reservation.refresh.time.ms" |
public static final String |
EXECUTOR_REFRESH_TIME_MS_DOC |
"The time, in milliseconds, after which a newly-acquired executor reservation which aborted an executor run should wait before being returned. Useful for edge cases where metadata in the underlying Kafka cluster isn\'t updated quickly enough." |
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 |
HOT_PARTITION_CAPACITY_UTILIZATION_THRESHOLD_CONFIG |
"hot.partition.capacity.utilization.threshold" |
public static final String |
INCREMENTAL_BALANCING_ENABLED_CONFIG |
"incremental.balancing.enabled" |
public static final String |
INCREMENTAL_BALANCING_ENABLED_DOC |
"A boolean value controlling whether to use incremental balancing strategy or not." |
public static final String |
INCREMENTAL_BALANCING_GOALS_CONFIG |
"incremental.balancing.goals.config" |
public static final String |
INCREMENTAL_BALANCING_GOALS_DOC |
"A list of case insensitive goals in the order of priority. The high priority goals will be executed first. This list of goals will be used for anomaly detection and balancing if incremental.balancing.enabled is set to true." |
public static final String |
INCREMENTAL_BALANCING_LOWER_BOUND_CONFIG |
"incremental.balancing.lower.bound" |
public static final String |
INCREMENTAL_BALANCING_LOWER_BOUND_DOC |
"A value in the interval [0, 1] representing the lower bound of replica movements from each incremental balancing round to prevent the long tail effect of incremental balancing. Take CPU usage for example, setting incremental.balancing.lower.bound to 0.02 will cause each incremental balancing round generates enough movements so that the change in CPU usage is at least 0.02 * 100% (Capacity of CPU usage) = 2% of the capacity. Combining with incremental.balancing.step.ratio, these two configurations facilitate the success criteria of an incremental balancing round." |
public static final String |
INCREMENTAL_BALANCING_STEP_RATIO_CONFIG |
"incremental.balancing.step.ratio" |
public static final String |
INCREMENTAL_BALANCING_STEP_RATIO_DOC |
"A value in the interval [0, 1] representing the step size of each incremental balancing round. For example, if an overloaded broker has 70% CPU usage and the mean CPU usage across the cluster is 50%, setting incremental.balancing.step.ratio to 0.2 will generate incremental balancing proposals that moves enough replicas off from the overloaded broker so that its CPU usage drops by 20% of the delta: (70% - 50%) * 0.2 = 4%." |
public static final String |
INTRA_BROKER_GOALS_CONFIG |
"intra.broker.goals" |
public static final String |
INVALID_REPLICA_ASSIGNMENT_RETRY_TIMEOUT_MS_CONFIG |
"invalid.replica.assignment.retry.timeout.ms" |
public static final String |
INVALID_REPLICA_ASSIGNMENT_RETRY_TIMEOUT_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 |
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 |
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_CLIENT_TIMEOUT_MS_CONFIG |
"metadata.client.timeout.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 |
RESOURCE_UTILIZATION_DETECTOR_ENABLED_CONFIG |
"resource.utilization.detector.enabled" |
public static final String |
RESOURCE_UTILIZATION_DETECTOR_INTERVAL_MS_CONFIG |
"resource.utilization.detector.interval.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 |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final String |
SHUTDOWN_TIMEOUT_MS_CONFIG |
"cdbe.shutdown.wait.ms" |
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 |
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" |