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() |
Long |
samplingIntervalWindowMs()
Returns the interval window, in milliseconds, in which we should sample metrics.
|
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, getBoolean, getClass, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, 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 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_CLASS_DEFAULT
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 CONSUMER_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_BALANCING_BALANCE_THRESHOLD_MULTIPLIER_CONFIG
topic.balancing.balance.threshold.multiplier
public static final double DEFAULT_TOPIC_BALANCING_BALANCE_THRESHOLD_MULTIPLIER
public static final String TOPIC_BALANCING_TRIGGER_THRESHOLD_MULTIPLIER_CONFIG
topic.balancing.trigger.threshold.multiplier
public static final double DEFAULT_TOPIC_BALANCING_TRIGGER_THRESHOLD_MULTIPLIER
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 CONSUMER_OUTBOUND_CAPACITY_THRESHOLD_CONFIG
consumer.outbound.capacity.threshold
public static final Double DEFAULT_CONSUMER_OUTBOUND_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 POPULATE_DEFAULT_DISK_CAPACITY_FROM_LOCAL_CONFIG
populate.default.disk.capacity.from.local
Since SBC runs on the quorum controller in a KRaft cluster, which can have a different disk size than the actual
broker, the wrong disk capacity will be used when SBC is trying to balance a cluster with new brokers being added.
This can cause frequent broker addition failures. We add this internal configuration to disable the default disk
capacity behaviour on Confluent Cloud. The default disk capacity will be derived from the existing brokers when
broker addition is underway if this configuration is set to false.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 ALTER_CONFIGS_RESPONSE_TIMEOUT_MS_CONFIG
alter.configs.response.timeout.ms
public static final Integer DEFAULT_ALTER_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 DYNAMIC_THROTTLING_ENABLED_CONFIG
dynamic.throttling.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 INCREMENTAL_BALANCING_MIN_VALID_WINDOWS_CONFIG
incremental.balancing.min.valid.windows
public static final String INCREMENTAL_BALANCING_MIN_VALID_WINDOWS_DOC
public static final int INCREMENTAL_BALANCING_MIN_VALID_WINDOWS_DEFAULT
public static final String SBC_METRICS_PARSER_ENABLED_CONFIG
sbc.metrics.parser.enabled
public static final String SBC_METRICS_PARSER_ENABLED_DOC
public static final Boolean SBC_METRICS_PARSER_ENABLED_DEFAULT
public static final String SELF_HEALING_MAXIMUM_ROUNDS_CONFIG
self.healing.maximum.rounds
public static final String SELF_HEALING_MAXIMUM_ROUNDS_DOC
public static final int SELF_HEALING_MAXIMUM_ROUNDS_DEFAULT
public static final String CPU_UTILIZATION_DETECTOR_ENABLED_CONFIG
public static final String DISK_UTILIZATION_DETECTOR_ENABLED_CONFIG
public static final String V2_ADDITION_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 BROKER_ADDITION_DETECTOR_CPU_PERCENT_COMPLETION_THRESHOLD_CONFIG
public static final String BROKER_ADDITION_DETECTOR_COMPLETION_DURATION_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 static final String ENABLE_CELLS_CONFIG
public static final String ENABLE_CELLS_DOC
public static final Boolean ENABLE_CELLS_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)
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
public Long samplingIntervalWindowMs()