public class KafkaCruiseControlConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG
anomaly.detection.allow.capacity.estimation |
static java.lang.String |
ANOMALY_DETECTION_GOALS_CONFIG
anomaly.detection.goals |
static java.lang.String |
ANOMALY_DETECTION_INTERVAL_MS_CONFIG
anomaly.detection.interval.ms |
static java.lang.String |
ANOMALY_NOTIFIER_CLASS_CONFIG
anomaly.notifier.class |
static long |
AUTO_THROTTLE |
static java.lang.String |
BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers |
static java.lang.String |
BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG
broker.capacity.config.resolver.class |
static java.lang.String |
BROKER_FAILURE_ALERT_THRESHOLD_MS_CONFIG
broker.failure.alert.threshold.ms |
static java.lang.String |
BROKER_FAILURE_ALERT_THRESHOLD_MS_DOC |
static java.lang.String |
BROKER_FAILURE_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG
broker.failure.exclude.recently.demoted.brokers |
static java.lang.String |
BROKER_FAILURE_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG
broker.failure.exclude.recently.removed.brokers |
static java.lang.String |
BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS_CONFIG
broker.failure.self.healing.threshold.ms |
static java.lang.String |
BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS_DOC |
static java.lang.String |
BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG
broker.metric.sample.aggregator.completeness.cache.size |
static java.lang.String |
BROKER_METRICS_WINDOW_MS_CONFIG
broker.metrics.window.ms |
static java.lang.String |
BROKER_REMOVAL_SHUTDOWN_MS_CONFIG
The amount of time to block for when waiting for the broker to be shut down.
|
static java.lang.String |
CALCULATED_THROTTLE_RATIO_CONFIG
calculated.throttle.ratio |
static java.lang.String |
CLIENT_ID_CONFIG
client.id |
static java.lang.String |
CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms |
static java.lang.String |
CPU_BALANCE_THRESHOLD_CONFIG
cpu.balance.threshold |
static java.lang.String |
CPU_CAPACITY_THRESHOLD_CONFIG
cpu.capacity.threshold |
static java.lang.String |
CPU_LOW_UTILIZATION_THRESHOLD_CONFIG
cpu.low.utilization.threshold |
static java.util.List<java.lang.String> |
DEFAULT_ANOMALY_DETECTION_GOALS_LIST |
static java.lang.Integer |
DEFAULT_ANOMALY_DETECTION_INTERVAL_MS |
static java.lang.String |
DEFAULT_API_TIMEOUT_MS_CONFIG
default.api.timeout.ms |
static int |
DEFAULT_API_TIMEOUT_MS_DEFAULT |
static java.lang.Long |
DEFAULT_BROKER_FAILURE_ALERT_THRESHOLD_MS |
static java.lang.Long |
DEFAULT_BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS |
static java.lang.Long |
DEFAULT_BROKER_METRICS_WINDOW_MS |
static java.lang.Long |
DEFAULT_BROKER_REMOVAL_SHUTDOWN_MS |
static java.lang.Double |
DEFAULT_CPU_CAPACITY_THRESHOLD |
static java.lang.Double |
DEFAULT_CPU_LOW_UTILIZATION_THRESHOLD |
static java.lang.Long |
DEFAULT_DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS |
static java.lang.Long |
DEFAULT_DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS |
static java.lang.Double |
DEFAULT_DISK_CAPACITY_THRESHOLD |
static java.lang.Double |
DEFAULT_DISK_LOW_UTILIZATION_THRESHOLD |
static java.lang.Double |
DEFAULT_GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER |
static java.util.List<java.lang.String> |
DEFAULT_GOALS_LIST |
static java.lang.Integer |
DEFAULT_METADATA_MAX_AGE_MS |
static java.lang.Long |
DEFAULT_METADATA_TTL |
static java.lang.Long |
DEFAULT_METRIC_SAMPLING_INTERVAL_MS |
static java.lang.Integer |
DEFAULT_MIN_SAMPLES_PER_BROKER_METRICS_WINDOW |
static java.lang.Integer |
DEFAULT_MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW |
static java.lang.Double |
DEFAULT_MIN_VALID_PARTITION_RATIO |
static java.lang.Double |
DEFAULT_NETWORK_INBOUND_CAPACITY_THRESHOLD |
static java.lang.Double |
DEFAULT_NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD |
static java.lang.Double |
DEFAULT_NETWORK_OUTBOUND_CAPACITY_THRESHOLD |
static java.lang.Double |
DEFAULT_NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD |
static java.lang.Integer |
DEFAULT_NUM_BROKER_METRICS_WINDOWS |
static java.lang.Integer |
DEFAULT_NUM_PARTITION_METRICS_WINDOWS |
static java.lang.Long |
DEFAULT_PARTITION_METRICS_MS |
static java.lang.Double |
DEFAULT_READ_THROUGHPUT_MULTIPLIER |
static java.lang.String |
DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG
default.replica.movement.strategies |
static java.lang.Double |
DEFAULT_WRITE_THROUGHPUT_MULTIPLIER |
static java.lang.String |
DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG
demotion.history.retention.time.ms |
static java.lang.String |
DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG
describe.cluster.response.timeout.ms |
static java.lang.String |
DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS_CONFIG
describe.topics.response.timeout.ms |
static java.lang.Long |
DISABLED_THROTTLE |
static java.lang.String |
DISK_BALANCE_THRESHOLD_CONFIG
disk.balance.threshold |
static java.lang.String |
DISK_CAPACITY_THRESHOLD_CONFIG
Disk capacity:
disk.max.load |
static java.lang.String |
DISK_LOW_UTILIZATION_THRESHOLD_CONFIG
disk.low.utilization.threshold |
static java.lang.String |
DISK_READ_RATIO_CONFIG
disk.read.ratio |
static java.lang.String |
EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG
execution.progress.check.interval.ms |
static java.lang.String |
EXECUTOR_NOTIFIER_CLASS_CONFIG |
static java.lang.String |
FOLLOWER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG
follower.network.inbound.weight.for.cpu.util |
static java.lang.String |
GOAL_BALANCEDNESS_PRIORITY_WEIGHT_CONFIG
goal.balancedness.priority.weight |
static java.lang.String |
GOAL_BALANCEDNESS_STRICTNESS_WEIGHT_CONFIG
goal.balancedness.strictness.weight |
static java.lang.String |
GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG
goal.violation.distribution.threshold.multiplier |
static java.lang.String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_DEMOTED_BROKERS_CONFIG
goal.violation.exclude.recently.demoted.brokers |
static java.lang.String |
GOAL_VIOLATION_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG
goal.violation.exclude.recently.removed.brokers |
static java.lang.String |
GOALS_CONFIG
goals |
static java.lang.String |
INTRA_BROKER_GOALS_CONFIG
intra.broker.goals |
static java.lang.String |
LEADER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG
leader.network.inbound.weight.for.cpu.util |
static java.lang.String |
LEADER_NETWORK_OUTBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG
leader.network.outbound.weight.for.cpu.util |
static java.lang.String |
LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
leader.replica.count.balance.threshold |
static java.lang.String |
LINEAR_REGRESSION_MODEL_CPU_UTIL_BUCKET_SIZE_CONFIG
linear.regression.model.cpu.util.bucket.size |
static java.lang.String |
LINEAR_REGRESSION_MODEL_MIN_NUM_CPU_UTIL_BUCKETS_CONFIG
linear.regression.model.min.num.cpu.util.buckets |
static java.lang.String |
LINEAR_REGRESSION_MODEL_REQUIRED_SAMPLES_PER_CPU_UTIL_BUCKET_CONFIG
linear.regression.model.required.samples.per.bucket |
static java.lang.String |
LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG
logdir.response.timeout.ms |
static java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG
max.allowed.extrapolations.per.broker |
static java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG
max.allowed.extrapolations.per.partition |
static java.lang.String |
MAX_REPLICAS_PER_BROKER_CONFIG
Broker replica capacity:
max.replicas |
static java.lang.String |
MAX_VOLUME_THROUGHPUT_MB_CONFIG
max.volume.throughput |
static java.lang.String |
METADATA_MAX_AGE_CONFIG
metadata.max.age.ms |
static java.lang.String |
METADATA_TTL_CONFIG
metadata.ttl |
static java.lang.String |
METRIC_SAMPLER_CLASS_CONFIG
metric.sampler.class |
static java.lang.String |
METRIC_SAMPLER_PARTITION_ASSIGNOR_CLASS_CONFIG
metric.sampler.partition.assignor.class |
static java.lang.String |
METRIC_SAMPLING_INTERVAL_MS_CONFIG
metric.sampling.interval.ms |
static java.lang.String |
MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG
min.samples.per.broker.metrics.window |
static java.lang.String |
MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG
min.samples.per.partition.metrics.window |
static java.lang.String |
MIN_VALID_PARTITION_RATIO_CONFIG
min.valid.partition.ratio |
static java.lang.String |
NETWORK_IN_CAPACITY_BYTES_CONFIG
Network Capacity values
|
static java.lang.String |
NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG
network.inbound.balance.threshold |
static java.lang.String |
NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG
network.inbound.capacity.threshold |
static java.lang.String |
NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.inbound.low.utilization.threshold |
static java.lang.String |
NETWORK_OUT_CAPACITY_BYTES_CONFIG |
static java.lang.String |
NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG
network.outbound.balance.threshold |
static java.lang.String |
NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG
network.outbound.capacity.threshold |
static java.lang.String |
NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.outbound.low.utilization.threshold |
static java.lang.Long |
NO_THROTTLE |
static java.lang.String |
NUM_BROKER_METRICS_WINDOWS_CONFIG
num.broker.metrics.windows |
static java.lang.String |
NUM_CACHED_RECENT_ANOMALY_STATES_CONFIG
num.cached.recent.anomaly.states |
static java.lang.String |
NUM_CACHED_RECENT_ANOMALY_STATES_DOC |
static java.lang.String |
NUM_CONCURRENT_INTRA_BROKER_PARTITION_MOVEMENTS_CONFIG
num.concurrent.intra.broker.partition.movements |
static java.lang.String |
NUM_CONCURRENT_LEADER_MOVEMENTS_CONFIG
num.concurrent.leader.movements |
static java.lang.String |
NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER_CONFIG
num.concurrent.partition.movements.per.broker |
static java.lang.String |
NUM_METRIC_FETCHERS_CONFIG
Deprecated.
(i.e. cannot be configured to a value other than 1).
num.metric.fetchers |
static java.lang.String |
NUM_PARTITION_METRICS_WINDOWS_CONFIG
num.partition.metrics.windows |
static java.lang.String |
OVERRIDE_STATIC_THROTTLES_CONFIG
static.throttle.rate.override.enabled |
static java.lang.String |
PARTITION_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG
partition.metric.sample.aggregator.completeness.cache.size |
static java.lang.String |
PARTITION_METRICS_WINDOW_MS_CONFIG
partition.metrics.windows.ms |
static java.lang.String |
PLAN_COMPUTATION_RETRY_INTERVAL_MS_DOC |
static java.lang.String |
PLAN_COMPUTATION_RETRY_TIMEOUT_MS_CONFIG
plan.computation.retry.timeout.ms |
static java.lang.Long |
PLAN_COMPUTATION_RETRY_TIMEOUT_MS_DEFAULT |
static java.lang.String |
READ_THROUGHPUT_MULTIPLIER_CONFIG
read.throughput.multiplier |
static java.lang.String |
RECEIVE_BUFFER_CONFIG
receive.buffer.bytes |
static java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms |
static java.lang.String |
REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG
removal.history.retention.time.ms |
static java.lang.String |
REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
replica.count.balance.threshold |
static java.lang.String |
REPLICA_MOVEMENT_STRATEGIES_CONFIG
replica.movement.strategies |
static java.lang.String |
REPLICATION_THROTTLE_CONFIG
Replication throttle:
throttle.bytes.per.second |
static java.lang.String |
REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms |
static java.lang.String |
SAMPLE_STORE_CLASS_CONFIG
sample.store.class |
static java.lang.String |
SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG
sampling.allow.cpu.capacity.estimation |
static java.lang.String |
SELF_HEALING_BROKER_FAILURE_ENABLED_CONFIG
self.healing.broker.failure.enabled |
static java.lang.String |
SELF_HEALING_BROKER_FAILURE_ENABLED_DOC |
static java.lang.String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_CONFIG
self.healing.goal.violation.enabled |
static java.lang.String |
SELF_HEALING_GOAL_VIOLATION_ENABLED_DOC |
static java.lang.String |
SELF_HEALING_GOALS_CONFIG
self.healing.goals |
static java.lang.String |
SEND_BUFFER_CONFIG
send.buffer.bytes |
static java.lang.String |
TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
topic.replica.count.balance.threshold |
static java.lang.String |
TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG
topics.excluded.from.partition.movement |
static java.lang.String |
USE_LINEAR_REGRESSION_MODEL_CONFIG
use.linear.regression.model |
static java.lang.String |
WRITE_THROUGHPUT_MULTIPLIER_CONFIG
write.throughput.multiplier |
static java.lang.String |
ZOOKEEPER_CONNECT_CONFIG
zookeeper.connect |
static java.lang.String |
ZOOKEEPER_SECURITY_ENABLED_CONFIG
zookeeper.security.enabled |
Constructor and Description |
---|
KafkaCruiseControlConfig(java.util.Map<?,?> originals) |
KafkaCruiseControlConfig(java.util.Map<?,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
<T> T |
getConfiguredInstance(java.lang.String key,
java.lang.Class<T> t) |
<T> T |
getConfiguredInstance(java.lang.String key,
java.lang.Class<T> t,
java.util.Map<java.lang.String,java.lang.Object> configOverrides) |
<T> java.util.List<T> |
getConfiguredInstances(java.lang.String key,
java.lang.Class<T> t) |
<T> java.util.List<T> |
getConfiguredInstances(java.lang.String key,
java.lang.Class<T> t,
java.util.Map<java.lang.String,java.lang.Object> configOverrides) |
java.util.Map<java.lang.String,java.lang.Object> |
mergedConfigValues() |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final java.lang.String METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
public static final java.lang.Integer DEFAULT_METADATA_MAX_AGE_MS
public static final java.lang.String CLIENT_ID_CONFIG
client.id
public static final java.lang.String SEND_BUFFER_CONFIG
send.buffer.bytes
public static final java.lang.String RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final java.lang.String METADATA_TTL_CONFIG
metadata.ttl
public static final java.lang.Long DEFAULT_METADATA_TTL
public static final java.lang.String DEFAULT_API_TIMEOUT_MS_CONFIG
default.api.timeout.ms
public static final int DEFAULT_API_TIMEOUT_MS_DEFAULT
public static final java.lang.String PARTITION_METRICS_WINDOW_MS_CONFIG
partition.metrics.windows.ms
public static final java.lang.Long DEFAULT_PARTITION_METRICS_MS
public static final java.lang.String NUM_PARTITION_METRICS_WINDOWS_CONFIG
num.partition.metrics.windows
public static final java.lang.Integer DEFAULT_NUM_PARTITION_METRICS_WINDOWS
public static final java.lang.String MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG
min.samples.per.partition.metrics.window
public static final java.lang.Integer DEFAULT_MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW
public static final java.lang.String MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG
max.allowed.extrapolations.per.partition
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 BROKER_METRICS_WINDOW_MS_CONFIG
broker.metrics.window.ms
public static final java.lang.Long DEFAULT_BROKER_METRICS_WINDOW_MS
public static final java.lang.String NUM_BROKER_METRICS_WINDOWS_CONFIG
num.broker.metrics.windows
public static final java.lang.Integer DEFAULT_NUM_BROKER_METRICS_WINDOWS
public static final java.lang.String MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG
min.samples.per.broker.metrics.window
public static final java.lang.Integer DEFAULT_MIN_SAMPLES_PER_BROKER_METRICS_WINDOW
public static final java.lang.String MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG
max.allowed.extrapolations.per.broker
public static final java.lang.String BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG
broker.metric.sample.aggregator.completeness.cache.size
@Deprecated public static final java.lang.String NUM_METRIC_FETCHERS_CONFIG
num.metric.fetchers
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
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.Long DEFAULT_METRIC_SAMPLING_INTERVAL_MS
public static final java.lang.String BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG
broker.capacity.config.resolver.class
public static final java.lang.String NETWORK_IN_CAPACITY_BYTES_CONFIG
public static final java.lang.String NETWORK_OUT_CAPACITY_BYTES_CONFIG
public static final java.lang.String MIN_VALID_PARTITION_RATIO_CONFIG
min.valid.partition.ratio
public static final java.lang.Double DEFAULT_MIN_VALID_PARTITION_RATIO
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 FOLLOWER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG
follower.network.inbound.weight.for.cpu.util
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_REQUIRED_SAMPLES_PER_CPU_UTIL_BUCKET_CONFIG
linear.regression.model.required.samples.per.bucket
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 CPU_BALANCE_THRESHOLD_CONFIG
cpu.balance.threshold
public static final java.lang.String DISK_BALANCE_THRESHOLD_CONFIG
disk.balance.threshold
public static final java.lang.String NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG
network.inbound.balance.threshold
public static final java.lang.String NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG
network.outbound.balance.threshold
public static final java.lang.String REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
replica.count.balance.threshold
public static final java.lang.String LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
leader.replica.count.balance.threshold
public static final java.lang.String TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
topic.replica.count.balance.threshold
public static final java.lang.String GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG
goal.violation.distribution.threshold.multiplier
public static final java.lang.Double DEFAULT_GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER
public static final java.lang.String CPU_CAPACITY_THRESHOLD_CONFIG
cpu.capacity.threshold
public static final java.lang.Double DEFAULT_CPU_CAPACITY_THRESHOLD
public static final java.lang.String DISK_CAPACITY_THRESHOLD_CONFIG
disk.max.load
public static final java.lang.Double DEFAULT_DISK_CAPACITY_THRESHOLD
public static final java.lang.String NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG
network.inbound.capacity.threshold
public static final java.lang.Double DEFAULT_NETWORK_INBOUND_CAPACITY_THRESHOLD
public static final java.lang.String NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG
network.outbound.capacity.threshold
public static final java.lang.Double DEFAULT_NETWORK_OUTBOUND_CAPACITY_THRESHOLD
public static final java.lang.String CPU_LOW_UTILIZATION_THRESHOLD_CONFIG
cpu.low.utilization.threshold
public static final java.lang.Double DEFAULT_CPU_LOW_UTILIZATION_THRESHOLD
public static final java.lang.String DISK_LOW_UTILIZATION_THRESHOLD_CONFIG
disk.low.utilization.threshold
public static final java.lang.Double DEFAULT_DISK_LOW_UTILIZATION_THRESHOLD
public static final java.lang.String NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.inbound.low.utilization.threshold
public static final java.lang.Double DEFAULT_NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD
public static final java.lang.String NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.outbound.low.utilization.threshold
public static final java.lang.Double DEFAULT_NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD
public static final java.lang.String MAX_REPLICAS_PER_BROKER_CONFIG
max.replicas
public static final java.lang.String ZOOKEEPER_CONNECT_CONFIG
zookeeper.connect
public static final java.lang.String ZOOKEEPER_SECURITY_ENABLED_CONFIG
zookeeper.security.enabled
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_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 REPLICATION_THROTTLE_CONFIG
throttle.bytes.per.second
public static final java.lang.Long NO_THROTTLE
public static final java.lang.Long DISABLED_THROTTLE
public static final long AUTO_THROTTLE
public static final java.lang.String REPLICA_MOVEMENT_STRATEGIES_CONFIG
replica.movement.strategies
public static final java.lang.String DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG
default.replica.movement.strategies
public static final java.lang.String EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG
execution.progress.check.interval.ms
public static final java.lang.String GOALS_CONFIG
goals
public static final java.util.List<java.lang.String> DEFAULT_GOALS_LIST
public static final java.lang.String INTRA_BROKER_GOALS_CONFIG
intra.broker.goals
public static final java.lang.String SELF_HEALING_GOALS_CONFIG
self.healing.goals
public static final java.lang.String ANOMALY_NOTIFIER_CLASS_CONFIG
anomaly.notifier.class
public static final java.lang.String EXECUTOR_NOTIFIER_CLASS_CONFIG
public static final java.lang.String ANOMALY_DETECTION_INTERVAL_MS_CONFIG
anomaly.detection.interval.ms
public static final java.lang.Integer DEFAULT_ANOMALY_DETECTION_INTERVAL_MS
public static final java.lang.String ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG
anomaly.detection.allow.capacity.estimation
public static final java.lang.String SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG
sampling.allow.cpu.capacity.estimation
public static final java.lang.String ANOMALY_DETECTION_GOALS_CONFIG
anomaly.detection.goals
public static final java.util.List<java.lang.String> DEFAULT_ANOMALY_DETECTION_GOALS_LIST
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 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 USE_LINEAR_REGRESSION_MODEL_CONFIG
use.linear.regression.model
public static final java.lang.String TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG
topics.excluded.from.partition.movement
public static final java.lang.String SAMPLE_STORE_CLASS_CONFIG
sample.store.class
public static final java.lang.String DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG
demotion.history.retention.time.ms
public static final java.lang.String REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG
removal.history.retention.time.ms
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 SELF_HEALING_BROKER_FAILURE_ENABLED_CONFIG
self.healing.broker.failure.enabled
public static final java.lang.String SELF_HEALING_BROKER_FAILURE_ENABLED_DOC
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
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
public static final java.lang.Long DEFAULT_BROKER_FAILURE_ALERT_THRESHOLD_MS
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
public static final java.lang.Long DEFAULT_BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS
public static final java.lang.String LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG
logdir.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.Long DEFAULT_DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS
public static final java.lang.String DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG
describe.cluster.response.timeout.ms
public static final java.lang.Long DEFAULT_DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS
public static final java.lang.String BROKER_REMOVAL_SHUTDOWN_MS_CONFIG
broker.removal.shutdown.timeout.ms
public static final java.lang.Long DEFAULT_BROKER_REMOVAL_SHUTDOWN_MS
public static final java.lang.String OVERRIDE_STATIC_THROTTLES_CONFIG
static.throttle.rate.override.enabled
public static final java.lang.String MAX_VOLUME_THROUGHPUT_MB_CONFIG
max.volume.throughput
public static final java.lang.String WRITE_THROUGHPUT_MULTIPLIER_CONFIG
write.throughput.multiplier
public static final java.lang.Double DEFAULT_WRITE_THROUGHPUT_MULTIPLIER
public static final java.lang.String READ_THROUGHPUT_MULTIPLIER_CONFIG
read.throughput.multiplier
public static final java.lang.Double DEFAULT_READ_THROUGHPUT_MULTIPLIER
public static final java.lang.String CALCULATED_THROTTLE_RATIO_CONFIG
calculated.throttle.ratio
public static final java.lang.String DISK_READ_RATIO_CONFIG
disk.read.ratio
public static final java.lang.String PLAN_COMPUTATION_RETRY_TIMEOUT_MS_CONFIG
plan.computation.retry.timeout.ms
public static final java.lang.String PLAN_COMPUTATION_RETRY_INTERVAL_MS_DOC
public static final java.lang.Long PLAN_COMPUTATION_RETRY_TIMEOUT_MS_DEFAULT
public KafkaCruiseControlConfig(java.util.Map<?,?> originals)
public KafkaCruiseControlConfig(java.util.Map<?,?> originals, boolean doLog)
public java.util.Map<java.lang.String,java.lang.Object> mergedConfigValues()
public <T> T getConfiguredInstance(java.lang.String key, java.lang.Class<T> t)
getConfiguredInstance
in class org.apache.kafka.common.config.AbstractConfig
public <T> java.util.List<T> getConfiguredInstances(java.lang.String key, java.lang.Class<T> t)
getConfiguredInstances
in class org.apache.kafka.common.config.AbstractConfig
public <T> java.util.List<T> getConfiguredInstances(java.lang.String key, java.lang.Class<T> t, java.util.Map<java.lang.String,java.lang.Object> configOverrides)
getConfiguredInstances
in class org.apache.kafka.common.config.AbstractConfig
public <T> T getConfiguredInstance(java.lang.String key, java.lang.Class<T> t, java.util.Map<java.lang.String,java.lang.Object> configOverrides)