public class KafkaCruiseControlConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
KafkaCruiseControlConfig(Map<?,?> originals) |
KafkaCruiseControlConfig(Map<?,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
KafkaCruiseControlConfig |
clone(Map<String,Object> newConfigKeyByValues)
Returns a clone of the Config with the given parameters modified
|
KafkaCruiseControlConfig |
clone(String newConfigKey,
Object newConfigValue)
Returns a clone of the Config with one parameter modified
|
<T> T |
getConfiguredInstance(String key,
Class<T> t) |
<T> T |
getConfiguredInstance(String key,
Class<T> t,
Map<String,Object> configOverrides) |
<T> List<T> |
getConfiguredInstances(String key,
Class<T> t) |
<T> List<T> |
getConfiguredInstances(String key,
Class<T> t,
Map<String,Object> configOverrides) |
static String |
internalGoalsConfigName(String externalName)
Given the higher-level
BalancerConfigs name for an SBC goal config, return the lower-level internal one that is used within KafkaCruiseControlConfig . |
Map<String,Object> |
mergedConfigValues() |
static Integer |
shutdownTimeoutMs(Map<String,Object> config)
Fetches the configured
SHUTDOWN_TIMEOUT_MS_CONFIG |
UpdatableSbcGoalsConfig |
updatableSbcGoalsConfig()
Gets or creates a
UpdatableSbcGoalsConfig from this config. |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String BOOTSTRAP_SERVERS_CONFIG
bootstrap.servers
public static final String CLIENT_ID_CONFIG
client.id
public static final String SEND_BUFFER_CONFIG
send.buffer.bytes
public static final String RECEIVE_BUFFER_CONFIG
receive.buffer.bytes
public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG
connections.max.idle.ms
public static final String RECONNECT_BACKOFF_MS_CONFIG
reconnect.backoff.ms
public static final String REQUEST_TIMEOUT_MS_CONFIG
request.timeout.ms
public static final String LEADER_ACTION_TIMEOUT_MS_CONFIG
executor.leader.action.timeout.ms
public static final String METADATA_TTL_CONFIG
metadata.ttl
public static final Long DEFAULT_METADATA_TTL
public static final String METADATA_CLIENT_TIMEOUT_MS_CONFIG
metadata.client.timeout.ms
public static final Integer DEFAULT_METADATA_CLIENT_TIMEOUT_MS
public static final String DEFAULT_API_TIMEOUT_MS_CONFIG
default.api.timeout.ms
public static final int DEFAULT_API_TIMEOUT_MS_DEFAULT
public static final String PARTITION_METRICS_WINDOW_MS_CONFIG
partition.metrics.windows.ms
public static final Long DEFAULT_PARTITION_METRICS_WINDOW_MS
public static final String NUM_PARTITION_METRICS_WINDOWS_CONFIG
num.partition.metrics.windows
public static final Integer DEFAULT_NUM_PARTITION_METRICS_WINDOWS
public static final String MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG
min.samples.per.partition.metrics.window
public static final Integer DEFAULT_MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW
public static final String MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG
max.allowed.extrapolations.per.partition
public static final String PARTITION_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG
partition.metric.sample.aggregator.completeness.cache.size
public static final String BROKER_METRICS_WINDOW_MS_CONFIG
broker.metrics.window.ms
public static final Long DEFAULT_BROKER_METRICS_WINDOW_MS
public static final String NUM_BROKER_METRICS_WINDOWS_CONFIG
num.broker.metrics.windows
public static final Integer DEFAULT_NUM_BROKER_METRICS_WINDOWS
public static final String MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG
min.samples.per.broker.metrics.window
public static final Integer DEFAULT_MIN_SAMPLES_PER_BROKER_METRICS_WINDOW
public static final String MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG
max.allowed.extrapolations.per.broker
public static final String BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG
broker.metric.sample.aggregator.completeness.cache.size
@Deprecated public static final String NUM_METRIC_FETCHERS_CONFIG
num.metric.fetchers
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
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 Long DEFAULT_METRIC_SAMPLING_INTERVAL_MS
public static final String BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG
broker.capacity.config.resolver.class
public static final String NETWORK_IN_CAPACITY_BYTES_CONFIG
public static final String PRODUCER_IN_CAPACITY_BYTES_CONFIG
public static final String NETWORK_OUT_CAPACITY_BYTES_CONFIG
public static final String MIN_VALID_PARTITION_RATIO_CONFIG
min.valid.partition.ratio
public static final Double DEFAULT_MIN_VALID_PARTITION_RATIO
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 FOLLOWER_NETWORK_INBOUND_WEIGHT_FOR_CPU_UTIL_CONFIG
follower.network.inbound.weight.for.cpu.util
public static final String HOT_PARTITION_CAPACITY_UTILIZATION_THRESHOLD_CONFIG
hot.partition.capacity.utilization.threshold
public static final Double HOT_PARTITION_CAPACITY_UTILIZATION_THRESHOLD_DEFAULT
public static final String CPU_BALANCE_THRESHOLD_CONFIG
cpu.balance.threshold
public static final Double DEFAULT_CPU_BALANCE_THRESHOLD
public static final String DISK_BALANCE_THRESHOLD_CONFIG
disk.balance.threshold
public static final Double DEFAULT_DISK_BALANCE_THRESHOLD
public static final String NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG
network.inbound.balance.threshold
public static final Double DEFAULT_NETWORK_INBOUND_BALANCE_THRESHOLD
public static final String NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG
network.outbound.balance.threshold
public static final Double DEFAULT_NETWORK_OUTBOUND_BALANCE_THRESHOLD
public static final String REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
replica.count.balance.threshold
public static final String LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
leader.replica.count.balance.threshold
public static final String TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG
topic.replica.count.balance.threshold
public static final String GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG
goal.violation.distribution.threshold.multiplier
public static final Double DEFAULT_GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER
public static final String CPU_CAPACITY_THRESHOLD_CONFIG
cpu.capacity.threshold
public static final Double DEFAULT_CPU_CAPACITY_THRESHOLD
public static final String DISK_CAPACITY_THRESHOLD_CONFIG
disk.max.load
public static final Double DEFAULT_DISK_CAPACITY_THRESHOLD
public static final String DISK_CAPACITY_MIN_FREE_SPACE_CONFIG
disk.min.free.space.gb
public static final Integer DEFAULT_DISK_CAPACITY_MIN_FREE_SPACE
public static final String NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG
network.inbound.capacity.threshold
public static final Double DEFAULT_NETWORK_INBOUND_CAPACITY_THRESHOLD
public static final String PRODUCER_INBOUND_CAPACITY_THRESHOLD_CONFIG
producer.inbound.capacity.threshold
public static final Double DEFAULT_PRODUCER_INBOUND_CAPACITY_THRESHOLD
public static final String NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG
network.outbound.capacity.threshold
public static final Double DEFAULT_NETWORK_OUTBOUND_CAPACITY_THRESHOLD
public static final String CPU_LOW_UTILIZATION_THRESHOLD_CONFIG
cpu.low.utilization.threshold
public static final Double DEFAULT_CPU_LOW_UTILIZATION_THRESHOLD
public static final String DISK_LOW_UTILIZATION_THRESHOLD_CONFIG
disk.low.utilization.threshold
public static final Double DEFAULT_DISK_LOW_UTILIZATION_THRESHOLD
public static final String NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.inbound.low.utilization.threshold
public static final Double DEFAULT_NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD
public static final String NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG
network.outbound.low.utilization.threshold
public static final Double DEFAULT_NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD
public static final String MAX_REPLICAS_PER_BROKER_CONFIG
max.replicas
public static final String ZOOKEEPER_CONNECT_CONFIG
zookeeper.connect
public static final String ZOOKEEPER_SECURITY_ENABLED_CONFIG
zookeeper.security.enabled
public static final String NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER_CONFIG
num.concurrent.partition.movements.per.broker
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 REPLICATION_THROTTLE_CONFIG
throttle.bytes.per.second
public static final Long DISABLED_THROTTLE
public static final long AUTO_THROTTLE
public static final String REPLICA_MOVEMENT_STRATEGIES_CONFIG
replica.movement.strategies
public static final String DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG
default.replica.movement.strategies
public static final String EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG
execution.progress.check.interval.ms
public static final String SHUTDOWN_TIMEOUT_MS_CONFIG
public static final String CC_STARTUP_RETRY_DURATION_HOURS_CONFIG
public static final String CC_STARTUP_RETRY_DELAY_MINUTES_CONFIG
public static final String GOALS_CONFIG
goals
public static final String INTRA_BROKER_GOALS_CONFIG
intra.broker.goals
public static final String ANOMALY_NOTIFIER_CLASS_CONFIG
anomaly.notifier.class
public static final String EXECUTOR_NOTIFIER_CLASS_CONFIG
public static final String ANOMALY_DETECTION_INTERVAL_MS_CONFIG
anomaly.detection.interval.ms
public static final Integer DEFAULT_ANOMALY_DETECTION_INTERVAL_MS
public static final String ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG
anomaly.detection.allow.capacity.estimation
public static final String SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG
sampling.allow.cpu.capacity.estimation
public static final String ANOMALY_DETECTION_GOALS_CONFIG
anomaly.detection.goals
public static final List<String> DEFAULT_ANOMALY_DETECTION_GOALS_LIST
public static final String BROKER_FAILURE_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG
broker.failure.exclude.recently.removed.brokers
public static final String GOAL_VIOLATION_EXCLUDE_RECENTLY_REMOVED_BROKERS_CONFIG
goal.violation.exclude.recently.removed.brokers
public static final String GOAL_VIOLATION_DELAY_ON_NEW_BROKER_MS_CONFIG
goal.violation.delay.on.broker.addition
public static final String GOAL_VIOLATION_DELAY_ON_NEW_BROKER_MS_DOC
public static final Long GOAL_VIOLATION_DELAY_ON_NEW_BROKERS_MS_DEFAULT
public static final String TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG
topics.excluded.from.partition.movement
public static final String PARTITION_METRIC_SAMPLE_STORE_TOPIC_CONFIG
partition.metric.sample.store.topic
public static final String DEFAULT_PARTITION_SAMPLE_STORE_TOPIC
public static final String PARTITION_METRIC_SAMPLE_STORE_TOPIC_DOC
public static final String BROKER_METRIC_SAMPLE_STORE_TOPIC_CONFIG
broker.metric.sample.store.topic
public static final String DEFAULT_BROKER_SAMPLE_STORE_TOPIC
public static final String BROKER_METRIC_SAMPLE_STORE_TOPIC_DOC
public static final String REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG
removal.history.retention.time.ms
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 SELF_HEALING_BROKER_FAILURE_ENABLED_CONFIG
self.healing.broker.failure.enabled
public static final String SELF_HEALING_BROKER_FAILURE_ENABLED_DOC
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
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
public static final Long DEFAULT_BROKER_FAILURE_ALERT_THRESHOLD_MS
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
public static final Long DEFAULT_BROKER_FAILURE_SELF_HEALING_THRESHOLD_MS
public static final String LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG
logdir.response.timeout.ms
public static final String DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS_CONFIG
describe.topics.response.timeout.ms
public static final Integer DEFAULT_DESCRIBE_TOPICS_RESPONSE_TIMEOUT_MS
public static final String DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG
describe.cluster.response.timeout.ms
public static final Integer DEFAULT_DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS
public static final String DESCRIBE_CONFIGS_RESPONSE_TIMEOUT_MS_CONFIG
describe.configs.response.timeout.ms
public static final Integer DEFAULT_DESCRIBE_CONFIGS_RESPONSE_TIMEOUT_MS
public static final String DESCRIBE_CONFIGS_BATCH_SIZE_CONFIG
public static final Integer DEFAULT_DESCRIBE_CONFIGS_BATCH_SIZE
public static final String BROKER_REMOVAL_SHUTDOWN_MS_CONFIG
broker.removal.shutdown.timeout.ms
public static final Long DEFAULT_BROKER_REMOVAL_SHUTDOWN_MS
public static final String BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_CONFIG
broker.exclusion.timeout.ms
public static final String BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_DOC
public static final Integer DEFAULT_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS
public static final String DESCRIBE_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_CONFIG
broker.exclusion.timeout.ms
public static final String DESCRIBE_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS_DOC
public static final Integer DEFAULT_DESCRIBE_BROKER_REPLICA_EXCLUSION_TIMEOUT_MS
public static final String OVERRIDE_STATIC_THROTTLES_CONFIG
static.throttle.rate.override.enabled
public static final String MAX_VOLUME_THROUGHPUT_MB_CONFIG
max.volume.throughput
public static final String WRITE_THROUGHPUT_MULTIPLIER_CONFIG
write.throughput.multiplier
public static final Double DEFAULT_WRITE_THROUGHPUT_MULTIPLIER
public static final String READ_THROUGHPUT_MULTIPLIER_CONFIG
read.throughput.multiplier
public static final Double DEFAULT_READ_THROUGHPUT_MULTIPLIER
public static final String CALCULATED_THROTTLE_RATIO_CONFIG
calculated.throttle.ratio
public static final String DISK_READ_RATIO_CONFIG
disk.read.ratio
public static final String PLAN_COMPUTATION_RETRY_TIMEOUT_MS_CONFIG
plan.computation.retry.timeout.ms
public static final String PLAN_COMPUTATION_RETRY_INTERVAL_MS_DOC
public static final Long PLAN_COMPUTATION_RETRY_TIMEOUT_MS_DEFAULT
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
public static final Long INVALID_REPLICA_ASSIGNMENT_RETRY_TIMEOUT_MS_DEFAULT
public static final String EXECUTOR_REFRESH_TIME_MS_CONFIG
public static final String EXECUTOR_REFRESH_TIME_MS_DOC
public static final Long EXECUTOR_REFRESH_TIME_MS_DEFAULT
public static final String REQUEST_CONTRIBUTION_WEIGHT_CONFIG
public static final double DEFAULT_REQUEST_CONTRIBUTION_WEIGHT
public static final String BYTES_CONTRIBUTION_WEIGHT_CONFIG
public static final double DEFAULT_BYTES_CONTRIBUTION_WEIGHT
public static final String CAPACITY_BALANCING_DELTA_PERCENTAGE_CONFIG
public static final Double CAPACITY_BALANCING_DELTA_PERCENTAGE_DEFAULT
public static final String CAPACITY_BALANCING_DELTA_PERCENTAGE_DOC
public static final String INCREMENTAL_BALANCING_ENABLED_CONFIG
incremental.balancing.enabled
public static final String INCREMENTAL_BALANCING_ENABLED_DOC
public static final Boolean INCREMENTAL_BALANCING_ENABLED_DEFAULT
public static final String INCREMENTAL_BALANCING_GOALS_CONFIG
incremental.balancing.goals.config
public static final String INCREMENTAL_BALANCING_GOALS_DOC
public static final List<String> INCREMENTAL_BALANCING_DEFAULT_GOALS_LIST
public static final String INCREMENTAL_BALANCING_STEP_RATIO_CONFIG
incremental.balancing.step.ratio
public static final String INCREMENTAL_BALANCING_STEP_RATIO_DOC
public static final Double INCREMENTAL_BALANCING_STEP_RATIO_DEFAULT
public static final String INCREMENTAL_BALANCING_LOWER_BOUND_CONFIG
incremental.balancing.lower.bound
public static final String INCREMENTAL_BALANCING_LOWER_BOUND_DOC
public static final Double INCREMENTAL_BALANCING_LOWER_BOUND_DEFAULT
public static final String RESOURCE_UTILIZATION_DETECTOR_ENABLED_CONFIG
public static final String RESOURCE_UTILIZATION_DETECTOR_INTERVAL_MS_CONFIG
public static final int DEFAULT_RESOURCE_UTILIZATION_DETECTOR_INTERVAL_MS
public static final String CPU_UTILIZATION_DETECTOR_DURATION_MS_CONFIG
public static final String CPU_UTILIZATION_DETECTOR_OVERUTILIZATION_THRESHOLD_CONFIG
public static final String CPU_UTILIZATION_DETECTOR_UNDERUTILIZATION_THRESHOLD_CONFIG
public static final String DISK_UTILIZATION_DETECTOR_DURATION_MS_CONFIG
public static final String DISK_UTILIZATION_DETECTOR_OVERUTILIZATION_THRESHOLD_CONFIG
public static final String DISK_UTILIZATION_DETECTOR_UNDERUTILIZATION_THRESHOLD_CONFIG
public static final String DISK_UTILIZATION_DETECTOR_RESERVED_CAPACITY_CONFIG
public static final String TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS_CONFIG
public static final long DEFAULT_TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS
public static final String TOPIC_PARTITION_MOVEMENT_EXPIRATION_MS_DOC
public static final String TOPIC_PARTITION_MAXIMUM_MOVEMENTS_CONFIG
public static final int DEFAULT_TOPIC_PARTITION_MAXIMUM_MOVEMENTS
public static final String TOPIC_PARTITION_MAXIMUM_MOVEMENTS_DOC
public static final String TOPIC_PARTITION_SUSPENSION_MS_CONFIG
public static final long DEFAULT_TOPIC_PARTITION_SUSPENSION_MS
public static final String TOPIC_PARTITION_SUSPENSION_MS_DOC
public KafkaCruiseControlConfig(Map<?,?> originals)
public KafkaCruiseControlConfig(Map<?,?> originals, boolean doLog)
public <T> T getConfiguredInstance(String key, Class<T> t)
getConfiguredInstance
in class org.apache.kafka.common.config.AbstractConfig
public <T> List<T> getConfiguredInstances(String key, Class<T> t)
getConfiguredInstances
in class org.apache.kafka.common.config.AbstractConfig
public <T> List<T> getConfiguredInstances(String key, Class<T> t, Map<String,Object> configOverrides)
getConfiguredInstances
in class org.apache.kafka.common.config.AbstractConfig
public <T> T getConfiguredInstance(String key, Class<T> t, Map<String,Object> configOverrides)
getConfiguredInstance
in class org.apache.kafka.common.config.AbstractConfig
public KafkaCruiseControlConfig clone(String newConfigKey, Object newConfigValue)
public KafkaCruiseControlConfig clone(Map<String,Object> newConfigKeyByValues)
public UpdatableSbcGoalsConfig updatableSbcGoalsConfig()
UpdatableSbcGoalsConfig
from this config.public static String internalGoalsConfigName(String externalName)
BalancerConfigs
name for an SBC goal config, return the lower-level internal one that is used within KafkaCruiseControlConfig
.public static Integer shutdownTimeoutMs(Map<String,Object> config)
SHUTDOWN_TIMEOUT_MS_CONFIG