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(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) |
Map<String,Object> |
mergedConfigValues() |
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 METADATA_MAX_AGE_CONFIG
metadata.max.age.ms
public static final Integer DEFAULT_METADATA_MAX_AGE_MS
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 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_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 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 LINEAR_REGRESSION_MODEL_CPU_UTIL_BUCKET_SIZE_CONFIG
linear.regression.model.cpu.util.bucket.size
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 LINEAR_REGRESSION_MODEL_MIN_NUM_CPU_UTIL_BUCKETS_CONFIG
linear.regression.model.min.num.cpu.util.buckets
public static final String CPU_BALANCE_THRESHOLD_CONFIG
cpu.balance.threshold
public static final String DISK_BALANCE_THRESHOLD_CONFIG
disk.balance.threshold
public static final String NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG
network.inbound.balance.threshold
public static final String NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG
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 NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG
network.inbound.capacity.threshold
public static final Double DEFAULT_NETWORK_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 GOALS_CONFIG
goals
public static final String INTRA_BROKER_GOALS_CONFIG
intra.broker.goals
public static final String SELF_HEALING_GOALS_CONFIG
self.healing.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_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 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 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 USE_LINEAR_REGRESSION_MODEL_CONFIG
use.linear.regression.model
public static final String TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG
topics.excluded.from.partition.movement
public static final String SAMPLE_STORE_CLASS_CONFIG
sample.store.class
public static final String NUM_SAMPLE_LOADING_THREADS_CONFIG
num.sample.loading.threads
public static final int DEFAULT_NUM_SAMPLE_LOADING_THREADS
public static final String NUM_SAMPLE_LOADING_THREADS_DOC
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 PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG
partition.sample.store.topic.partition.count
public static final int DEFAULT_PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT
public static final String PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT_DOC
public static final String MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG
min.partition.sample.store.topic.retention.time.ms
public static final long DEFAULT_MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS
public static final String MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_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 BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG
broker.sample.store.topic.partition.count
public static final int DEFAULT_BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT
public static final String BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT_DOC
public static final String MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG
min.broker.sample.store.topic.retention.time.ms
public static final long DEFAULT_MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS
public static final String MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_DOC
public static final String MAX_SAMPLE_LOAD_TIME_MS_CONFIG
samples.load.time.max.ms
public static final long DEFAULT_MAX_SAMPLE_LOAD_TIME_MS_CONFIG
public static final String MAX_SAMPLE_LOAD_TIME_MS_DOC
public static final String DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG
demotion.history.retention.time.ms
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 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_INTERVAL_MS_DOC
public static final Long INVALID_REPLICA_ASSIGNMENT_RETRY_TIMEOUT_MS_DEFAULT
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)