Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INVALID_INDEX |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HIDDEN |
"[hidden]" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_ENTITY_CONFIG |
"max.allowed.extrapolations.per.entity" |
public static final java.lang.String |
METRIC_ANOMALY_FINDER_METRICS_CONFIG |
"metric.anomaly.analyzer.metrics" |
public static final java.lang.String |
METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"metric.sample.aggregator.completeness.cache.size" |
public static final java.lang.String |
METRICS_WINDOW_MS_CONFIG |
"metrics.window.ms" |
public static final java.lang.String |
MIN_SAMPLES_PER_METRICS_WINDOW_CONFIG |
"min.samples.per.metrics.window" |
public static final java.lang.String |
NUM_METRICS_WINDOWS_CONFIG |
"num.metrics.windows" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
METRIC_ANOMALY_LOWER_MARGIN_CONFIG |
"metric.anomaly.lower.margin" |
public static final java.lang.String |
METRIC_ANOMALY_PERCENTILE_LOWER_THRESHOLD_CONFIG |
"metric.anomaly.percentile.lower.threshold" |
public static final java.lang.String |
METRIC_ANOMALY_PERCENTILE_UPPER_THRESHOLD_CONFIG |
"metric.anomaly.percentile.upper.threshold" |
public static final java.lang.String |
METRIC_ANOMALY_UPPER_MARGIN_CONFIG |
"metric.anomaly.upper.margin" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
ADMIN_CLIENT_CLOSE_TIMEOUT_MS |
10000L |
public static final int |
BYTES_IN_MB |
1048576 |
public static final java.lang.String |
DATE_FORMAT |
"YYYY-MM-dd_HH:mm:ss z" |
public static final java.lang.String |
DATE_FORMAT2 |
"dd/MM/yyyy HH:mm:ss" |
public static final long |
KAFKA_ZK_CLIENT_CLOSE_TIMEOUT_MS |
10000L |
public static final double |
MAX_BALANCEDNESS_SCORE |
100.0 |
public static final java.lang.String |
OPERATION_LOGGER |
"operationLogger" |
public static final int |
SEC_TO_MS |
1000 |
public static final java.lang.String |
TIME_ZONE |
"UTC" |
public static final java.lang.String |
ZK_CLIENT_NAME |
"Cruise Control ZK Client" |
public static final int |
ZK_CONNECTION_TIMEOUT |
30000 |
public static final int |
ZK_SESSION_TIMEOUT |
30000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BROKERS |
"brokers" |
public static final double |
EPSILON |
1.0E-5 |
public static final java.lang.String |
LEADER_REPLICAS |
"leaderReplicas" |
public static final java.lang.String |
METADATA |
"metadata" |
public static final java.lang.String |
POTENTIAL_NW_OUT |
"potentialNwOut" |
public static final java.lang.String |
REPLICAS |
"replicas" |
public static final java.lang.String |
STATISTICS |
"statistics" |
public static final java.lang.String |
TOPIC_REPLICAS |
"topicReplicas" |
public static final java.lang.String |
TOPICS |
"topics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MIN_NUM_VALID_WINDOWS_FOR_SELF_HEALING |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CAPACITY_CONFIG_FILE |
"capacity.config.file" |
public static final int |
DEFAULT_CAPACITY_BROKER_ID |
-1 |
public static final double |
DEFAULT_CPU_CAPACITY_WITH_CORES |
100.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
DEFAULT_NUM_CPU_CORES |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_CAPACITY_BROKER_ID |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ANOMALY_DETECTION_ALLOW_CAPACITY_ESTIMATION_CONFIG |
"anomaly.detection.allow.capacity.estimation" |
public static final java.lang.String |
ANOMALY_DETECTION_GOALS_CONFIG |
"anomaly.detection.goals" |
public static final java.lang.String |
ANOMALY_DETECTION_INTERVAL_MS_CONFIG |
"anomaly.detection.interval.ms" |
public static final java.lang.String |
ANOMALY_NOTIFIER_CLASS_CONFIG |
"anomaly.notifier.class" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
BROKER_CAPACITY_CONFIG_RESOLVER_CLASS_CONFIG |
"broker.capacity.config.resolver.class" |
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 |
"Grace period in milliseconds for a failed broker to rejoin the cluster before firing an alert" |
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 |
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 |
"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 java.lang.String |
BROKER_METRIC_SAMPLE_AGGREGATOR_COMPLETENESS_CACHE_SIZE_CONFIG |
"broker.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.String |
BROKER_REMOVAL_SHUTDOWN_MS_CONFIG |
"broker.removal.shutdown.timeout.ms" |
public static final java.lang.String |
CALCULATED_THROTTLE_RATIO_CONFIG |
"calculated.throttle.ratio" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
CONNECTIONS_MAX_IDLE_MS_CONFIG |
"connections.max.idle.ms" |
public static final java.lang.String |
CPU_BALANCE_THRESHOLD_CONFIG |
"cpu.balance.threshold" |
public static final java.lang.String |
CPU_CAPACITY_THRESHOLD_CONFIG |
"cpu.capacity.threshold" |
public static final java.lang.String |
CPU_LOW_UTILIZATION_THRESHOLD_CONFIG |
"cpu.low.utilization.threshold" |
public static final java.lang.String |
DEFAULT_API_TIMEOUT_MS_CONFIG |
"default.api.timeout.ms" |
public static final int |
DEFAULT_API_TIMEOUT_MS_DEFAULT |
60000 |
public static final java.lang.String |
DEFAULT_GOALS_CONFIG |
"default.goals" |
public static final java.lang.String |
DEFAULT_REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"default.replica.movement.strategies" |
public static final java.lang.String |
DEMOTION_HISTORY_RETENTION_TIME_MS_CONFIG |
"demotion.history.retention.time.ms" |
public static final java.lang.String |
DESCRIBE_CLUSTER_RESPONSE_TIMEOUT_MS_CONFIG |
"describe.cluster.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.String |
DISK_BALANCE_THRESHOLD_CONFIG |
"disk.balance.threshold" |
public static final java.lang.String |
DISK_CAPACITY_THRESHOLD_CONFIG |
"disk.max.load" |
public static final java.lang.String |
DISK_LOW_UTILIZATION_THRESHOLD_CONFIG |
"disk.low.utilization.threshold" |
public static final java.lang.String |
DISK_READ_RATIO_CONFIG |
"disk.read.ratio" |
public static final java.lang.String |
EXECUTION_PROGRESS_CHECK_INTERVAL_MS_CONFIG |
"execution.progress.check.interval.ms" |
public static final java.lang.String |
EXECUTOR_NOTIFIER_CLASS_CONFIG |
"executor.notifier.class" |
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 |
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 |
GOAL_VIOLATION_DISTRIBUTION_THRESHOLD_MULTIPLIER_CONFIG |
"goal.violation.distribution.threshold.multiplier" |
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 |
GOALS_CONFIG |
"goals" |
public static final java.lang.String |
HARD_GOALS_CONFIG |
"hard.goals" |
public static final java.lang.String |
INTRA_BROKER_GOALS_CONFIG |
"intra.broker.goals" |
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 |
LEADER_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"leader.replica.count.balance.threshold" |
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_MIN_NUM_CPU_UTIL_BUCKETS_CONFIG |
"linear.regression.model.min.num.cpu.util.buckets" |
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 |
LOGDIR_RESPONSE_TIMEOUT_MS_CONFIG |
"logdir.response.timeout.ms" |
public static final java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_BROKER_CONFIG |
"max.allowed.extrapolations.per.broker" |
public static final java.lang.String |
MAX_ALLOWED_EXTRAPOLATIONS_PER_PARTITION_CONFIG |
"max.allowed.extrapolations.per.partition" |
public static final java.lang.String |
MAX_REPLICAS_PER_BROKER_CONFIG |
"max.replicas" |
public static final java.lang.String |
MAX_VOLUME_THROUGHPUT_MB_CONFIG |
"max.volume.throughput.mb" |
public static final java.lang.String |
METADATA_MAX_AGE_CONFIG |
"metadata.max.age.ms" |
public static final java.lang.String |
METADATA_TTL_CONFIG |
"metadata.ttl" |
public static final java.lang.String |
METRIC_ANOMALY_FINDER_CLASSES_CONFIG |
"metric.anomaly.finder.class" |
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.String |
MIN_SAMPLES_PER_BROKER_METRICS_WINDOW_CONFIG |
"min.samples.per.broker.metrics.window" |
public static final java.lang.String |
MIN_SAMPLES_PER_PARTITION_METRICS_WINDOW_CONFIG |
"min.samples.per.partition.metrics.window" |
public static final java.lang.String |
MIN_VALID_PARTITION_RATIO_CONFIG |
"min.valid.partition.ratio" |
public static final java.lang.String |
NETWORK_IN_CAPACITY_BYTES_CONFIG |
"network.in.max.bytes.per.second" |
public static final java.lang.String |
NETWORK_INBOUND_BALANCE_THRESHOLD_CONFIG |
"network.inbound.balance.threshold" |
public static final java.lang.String |
NETWORK_INBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.inbound.capacity.threshold" |
public static final java.lang.String |
NETWORK_INBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.inbound.low.utilization.threshold" |
public static final java.lang.String |
NETWORK_OUT_CAPACITY_BYTES_CONFIG |
"network.out.max.bytes.per.second" |
public static final java.lang.String |
NETWORK_OUTBOUND_BALANCE_THRESHOLD_CONFIG |
"network.outbound.balance.threshold" |
public static final java.lang.String |
NETWORK_OUTBOUND_CAPACITY_THRESHOLD_CONFIG |
"network.outbound.capacity.threshold" |
public static final java.lang.String |
NETWORK_OUTBOUND_LOW_UTILIZATION_THRESHOLD_CONFIG |
"network.outbound.low.utilization.threshold" |
public static final java.lang.String |
NUM_BROKER_METRICS_WINDOWS_CONFIG |
"num.broker.metrics.windows" |
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 |
"The number of recent anomaly states cached for different anomaly types presented via the anomaly substate response of the state endpoint." |
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 |
NUM_CONCURRENT_PARTITION_MOVEMENTS_PER_BROKER_CONFIG |
"num.concurrent.partition.movements.per.broker" |
public static final java.lang.String |
NUM_METRIC_FETCHERS_CONFIG |
"num.metric.fetchers" |
public static final java.lang.String |
NUM_PARTITION_METRICS_WINDOWS_CONFIG |
"num.partition.metrics.windows" |
public static final java.lang.String |
NUM_PROPOSAL_PRECOMPUTE_THREADS_CONFIG |
"num.proposal.precompute.threads" |
public static final java.lang.String |
OVERRIDE_STATIC_THROTTLES_CONFIG |
"static.throttle.rate.override.enabled" |
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 |
PARTITION_METRICS_WINDOW_MS_CONFIG |
"partition.metrics.window.ms" |
public static final java.lang.String |
PROPOSAL_EXPIRATION_MS_CONFIG |
"proposal.expiration.ms" |
public static final java.lang.String |
READ_THROUGHPUT_MULTIPLIER_CONFIG |
"read.throughput.multiplier" |
public static final java.lang.String |
RECEIVE_BUFFER_CONFIG |
"receive.buffer.bytes" |
public static final java.lang.String |
RECONNECT_BACKOFF_MS_CONFIG |
"reconnect.backoff.ms" |
public static final java.lang.String |
REMOVAL_HISTORY_RETENTION_TIME_MS_CONFIG |
"removal.history.retention.time.ms" |
public static final java.lang.String |
REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"replica.count.balance.threshold" |
public static final java.lang.String |
REPLICA_MOVEMENT_STRATEGIES_CONFIG |
"replica.movement.strategies" |
public static final java.lang.String |
REPLICATION_THROTTLE_CONFIG |
"throttle.bytes.per.second" |
public static final java.lang.String |
REQUEST_TIMEOUT_MS_CONFIG |
"request.timeout.ms" |
public static final java.lang.String |
SAMPLE_STORE_CLASS_CONFIG |
"sample.store.class" |
public static final java.lang.String |
SAMPLING_ALLOW_CPU_CAPACITY_ESTIMATION_CONFIG |
"sampling.allow.cpu.capacity.estimation" |
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 |
"Enable self healing for broker failure detector." |
public static final java.lang.String |
SELF_HEALING_DISK_FAILURE_ENABLED_CONFIG |
"self.healing.disk.failure.enabled" |
public static final java.lang.String |
SELF_HEALING_DISK_FAILURE_ENABLED_DOC |
"Enable self healing for disk failure detector." |
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 |
"Enable self healing for goal violation detector." |
public static final java.lang.String |
SELF_HEALING_GOALS_CONFIG |
"self.healing.goals" |
public static final java.lang.String |
SELF_HEALING_METRIC_ANOMALY_ENABLED_CONFIG |
"self.healing.metric.anomaly.enabled" |
public static final java.lang.String |
SELF_HEALING_METRIC_ANOMALY_ENABLED_DOC |
"Enable self healing for metric anomaly detector." |
public static final java.lang.String |
SEND_BUFFER_CONFIG |
"send.buffer.bytes" |
public static final java.lang.String |
TOPIC_REPLICA_COUNT_BALANCE_THRESHOLD_CONFIG |
"topic.replica.count.balance.threshold" |
public static final java.lang.String |
TOPICS_EXCLUDED_FROM_PARTITION_MOVEMENT_CONFIG |
"topics.excluded.from.partition.movement" |
public static final java.lang.String |
USE_LINEAR_REGRESSION_MODEL_CONFIG |
"use.linear.regression.model" |
public static final java.lang.String |
WRITE_THROUGHPUT_MULTIPLIER_CONFIG |
"write.throughput.multiplier" |
public static final java.lang.String |
ZOOKEEPER_CONNECT_CONFIG |
"zookeeper.connect" |
public static final java.lang.String |
ZOOKEEPER_SECURITY_ENABLED_CONFIG |
"zookeeper.security.enabled" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_METADATA_WAIT_MS |
60000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KAFKA_CRUISE_CONTROL_OBJECT_CONFIG |
"kafka.cruise.control.object" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_SLACK_SELF_HEALING_NOTIFIER_ICON |
":information_source:" |
public static final java.lang.String |
DEFAULT_SLACK_SELF_HEALING_NOTIFIER_USER |
"Cruise Control" |
public static final java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_CHANNEL |
"slack.self.healing.notifier.channel" |
public static final java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_ICON |
"slack.self.healing.notifier.icon" |
public static final java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_USER |
"slack.self.healing.notifier.user" |
public static final java.lang.String |
SLACK_SELF_HEALING_NOTIFIER_WEBHOOK |
"slack.self.healing.notifier.webhook" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ATTRIBUTE_MAX |
"Max" |
public static final java.lang.String |
ATTRIBUTE_MEAN |
"Mean" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BROKER_ID |
"brokerid" |
public static final java.lang.String |
BROKER_STATE |
"brokerstate" |
public static final java.lang.String |
BROKERS |
"brokers" |
public static final java.lang.String |
HOSTS |
"hosts" |
public static final java.lang.String |
IS_LEADER |
"isLeader" |
public static final java.lang.String |
LOAD |
"load" |
public static final java.lang.String |
METRIC_VALUES |
"MetricValues" |
public static final java.lang.String |
NAME |
"name" |
public static final java.lang.String |
PARTITION |
"partition" |
public static final java.lang.String |
RACK_ID |
"rackid" |
public static final java.lang.String |
REPLICAS |
"replicas" |
public static final java.lang.String |
TOPIC |
"topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CLUSTER_GENERATION_ACCEPTABLE_STALENESS_LAG |
1 |
public static final int |
LOAD_GENERATION_ACCEPTABLE_STALENESS_LAG |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final double |
UNIT_INTERVAL_TO_PERCENTAGE |
100.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
METRIC_REPORTER_SAMPLER_BOOTSTRAP_SERVERS |
"metric.reporter.sampler.bootstrap.servers" |
public static final java.lang.String |
METRIC_REPORTER_SAMPLER_GROUP_ID |
"metric.reporter.sampler.group.id" |
public static final java.lang.String |
METRIC_REPORTER_TOPIC |
"metric.reporter.topic" |
public static final java.lang.String |
METRIC_REPORTER_TOPIC_PATTERN |
"metric.reporter.topic.pattern" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BROKER_METRIC_SAMPLE_STORE_TOPIC_CONFIG |
"broker.metric.sample.store.topic" |
public static final java.lang.String |
BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG |
"broker.sample.store.topic.partition.count" |
protected static final java.lang.String |
CONSUMER_CLIENT_ID |
"ConfluentBalancerSampleStoreConsumer" |
protected static final java.lang.String |
CONSUMER_GROUP |
"ConfluentBalancerSampleStoreGroup" |
protected static final int |
DEFAULT_BROKER_SAMPLE_STORE_TOPIC_PARTITION_COUNT |
32 |
protected static final long |
DEFAULT_MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS |
3600000L |
protected static final long |
DEFAULT_MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS |
3600000L |
protected static final int |
DEFAULT_NUM_SAMPLE_LOADING_THREADS |
2 |
protected static final int |
DEFAULT_PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT |
32 |
protected static final boolean |
DEFAULT_SKIP_SAMPLE_STORE_TOPIC_RACK_AWARENESS_CHECK |
true |
public static final java.lang.String |
MIN_BROKER_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG |
"min.broker.sample.store.topic.retention.time.ms" |
public static final java.lang.String |
MIN_PARTITION_SAMPLE_STORE_TOPIC_RETENTION_TIME_MS_CONFIG |
"min.partition.sample.store.topic.retention.time.ms" |
public static final java.lang.String |
NUM_SAMPLE_LOADING_THREADS_CONFIG |
"num.sample.loading.threads" |
public static final java.lang.String |
PARTITION_METRIC_SAMPLE_STORE_TOPIC_CONFIG |
"partition.metric.sample.store.topic" |
public static final java.lang.String |
PARTITION_SAMPLE_STORE_TOPIC_PARTITION_COUNT_CONFIG |
"partition.sample.store.topic.partition.count" |
protected static final java.lang.String |
PRODUCER_CLIENT_ID |
"ConfluentBalancerSampleStoreProducer" |
public static final java.lang.String |
SKIP_SAMPLE_STORE_TOPIC_RACK_AWARENESS_CHECK_CONFIG |
"skip.sample.store.topic.rack.awareness.check" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BROKER_CAPACITY_CONFIG_RESOLVER_OBJECT_CONFIG |
"broker.capacity.config.resolver.object" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
LATEST_SUPPORTED_VERSION |
6 |
public static final byte |
MIN_SUPPORTED_VERSION |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
ANALYZER_STATE |
"AnalyzerState" |
protected static final java.lang.String |
ANOMALY_DETECTOR_STATE |
"AnomalyDetectorState" |
protected static final java.lang.String |
EXECUTOR_STATE |
"ExecutorState" |
protected static final java.lang.String |
INTER_BROKER_PARTITION_MOVEMENTS |
"inter-broker partition movements" |
protected static final java.lang.String |
INTRA_BROKER_PARTITION_MOVEMENTS |
"intra-broker partition movements" |
protected static final java.lang.String |
LEADERSHIP_MOVEMENTS |
"leadership movements" |
protected static final java.lang.String |
MONITOR_STATE |
"MonitorState" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
CLUSTER_MODEL_STATS |
"clusterModelStats" |
protected static final java.lang.String |
FIXED |
"FIXED" |
protected static final java.lang.String |
GOAL |
"goal" |
protected static final java.lang.String |
GOAL_SUMMARY |
"goalSummary" |
public static final int |
JSON_VERSION |
1 |
protected static final java.lang.String |
LOAD_AFTER_OPTIMIZATION |
"loadAfterOptimization" |
protected static final java.lang.String |
LOAD_BEFORE_OPTIMIZATION |
"loadBeforeOptimization" |
protected static final java.lang.String |
NO_ACTION |
"NO-ACTION" |
protected static final java.lang.String |
PROPOSALS |
"proposals" |
protected static final java.lang.String |
STATUS |
"status" |
protected static final java.lang.String |
SUMMARY |
"summary" |
public static final java.lang.String |
VERSION |
"version" |
protected static final java.lang.String |
VIOLATED |
"VIOLATED" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
BROKERS |
"brokers" |
protected static final java.lang.String |
HOST |
"Host" |
protected static final java.lang.String |
HOSTS |
"hosts" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
BROKER |
"Broker" |
protected static final java.lang.String |
BROKER_STATE |
"BrokerState" |
protected static final java.lang.String |
DISK_STATE |
"DiskState" |
protected static final java.lang.String |
HOST |
"Host" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
METRIC_SAMPLER_BOOTSTRAP_SERVERS |
"metric.reporter.sampler.bootstrap.servers" |
public static final java.lang.String |
METRIC_SAMPLER_GROUP_ID |
"metric.reporter.sampler.group.id" |
public static final java.lang.String |
TELEMETRY_REPORTER_TOPIC_PATTERN |
"confluent.telemetry.reporter.topic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ACTIVE_BALANCER_COUNT_METRIC_NAME |
"ActiveBalancerCount" |
public static final java.lang.String |
BROKER_ADD_COUNT_METRIC_NAME |
"BrokerAddCount" |
public static final java.lang.String |
BROKER_REMOVAL_STATE_METRIC_NAME |
"BrokerRemovalOperationState" |