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_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 |
BYTES_CONTRIBUTION_WEIGHT_CONFIG |
"bytes.cpu.contribution.weight" |
public static final String |
CALCULATED_THROTTLE_RATIO_CONFIG |
"calculated.throttle.ratio" |
public static final String |
CAPACITY_BALANCING_DELTA_PERCENTAGE_CONFIG |
"max.capacity.balancing.delta.percentage" |
public static final String |
CAPACITY_BALANCING_DELTA_PERCENTAGE_DOC |
"The extra percentage of total capacity that SBC will attempt to balance below the allowed capacity once it gets triggered to fix a broker hitting its maximum allowed capacity for a given resource." |
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 double |
DEFAULT_BYTES_CONTRIBUTION_WEIGHT |
0.2 |
public static final String |
DEFAULT_PARTITION_SAMPLE_STORE_TOPIC |
"_confluent_balancer_partition_samples" |
public static final String |
DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"default.replica.movement.strategies" |
public static final double |
DEFAULT_REQUEST_CONTRIBUTION_WEIGHT |
0.8 |
public static final int |
DEFAULT_RESOURCE_UTILIZATION_DETECTOR_INTERVAL_MS |
60000 |
public static final int |
DEFAULT_TOPIC_PARTITION_MAXIMUM_MOVEMENTS |
5 |
public static final long |
DEFAULT_TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS |
3600000L |
public static final long |
DEFAULT_TOPIC_PARTITION_SUSPENSION_MS |
10800000L |
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_MIN_FREE_SPACE_CONFIG |
"disk.min.free.space.gb" |
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 |
DISK_UTILIZATION_DETECTOR_DURATION_MS_CONFIG |
"disk.utilization.detector.duration.ms" |
public static final String |
DISK_UTILIZATION_DETECTOR_OVERUTILIZATION_THRESHOLD_CONFIG |
"disk.utilization.detector.overutilization.threshold" |
public static final String |
DISK_UTILIZATION_DETECTOR_RESERVED_CAPACITY_CONFIG |
"disk.utilization.detector.reserved.capacity" |
public static final String |
DISK_UTILIZATION_DETECTOR_UNDERUTILIZATION_THRESHOLD_CONFIG |
"disk.utilization.detector.underutilization.threshold" |
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_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" |
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 retry the failed proposal due to an invalid replica assignment on the same proposal. " |
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_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_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_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 |
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 |
PRODUCER_IN_CAPACITY_BYTES_CONFIG |
"producer.in.max.bytes.per.second" |
public static final String |
PRODUCER_INBOUND_CAPACITY_THRESHOLD_CONFIG |
"producer.inbound.capacity.threshold" |
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_CONTRIBUTION_WEIGHT_CONFIG |
"request.cpu.contribution.weight" |
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 |
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_PARTITION_MAXIMUM_MOVEMENTS_CONFIG |
"topic.partition.maximum.movements" |
public static final String |
TOPIC_PARTITION_MAXIMUM_MOVEMENTS_DOC |
"Maximum number of repeated movements allowed for one TopicPartition in the rolling window whose length is defined by topic.partition.movement.expiration.ms" |
public static final String |
TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS_CONFIG |
"topic.partition.movement.expiration.ms" |
public static final String |
TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS_DOC |
"The duration in milliseconds for which a topic partition movement will be kept for observability and oscillation prevention. Effectively, SBC maintains a rolling window of topic partition movements whose length is defined by this configuration." |
public static final String |
TOPIC_PARTITION_SUSPENSION_MS_CONFIG |
"topic.partition.suspension.ms" |
public static final String |
TOPIC_PARTITION_SUSPENSION_MS_DOC |
"The duration in milliseconds for which a topic partition will be suspended for goal optimization if number of repeated movements within the rolling window defined by topic.partition.movement.expiration.ms exceeds the maximum allowed number defined by topic.partition.maximum.movements." |
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" |