Modifier and Type | Field and Description |
---|---|
protected OptimizationResult |
optimizationResult |
Constructor and Description |
---|
BrokerFailures(KafkaCruiseControl kafkaCruiseControl,
Map<Integer,Long> failedBrokers,
boolean allowCapacityEstimation,
boolean excludeRecentlyRemovedBrokers,
GoalsConfig goalConfig)
An anomaly to indicate broker failure(s).
|
Modifier and Type | Method and Description |
---|---|
String |
anomalyId() |
Map<Integer,Long> |
failedBrokers()
Get the failed broker list and their failure time in millisecond.
|
boolean |
fix()
Fix the anomaly with the system.
|
GoalsConfig |
goalsConfig()
Returns the goals that will be used to fix this anomaly.
|
String |
toString() |
protected OptimizationResult optimizationResult
public BrokerFailures(KafkaCruiseControl kafkaCruiseControl, Map<Integer,Long> failedBrokers, boolean allowCapacityEstimation, boolean excludeRecentlyRemovedBrokers, GoalsConfig goalConfig)
kafkaCruiseControl
- The Kafka Cruise Control instance.failedBrokers
- Failed broker ids by the detection time, or null for AnomalyDetectorUtils.SHUTDOWN_ANOMALY
allowCapacityEstimation
- Allow capacity estimation in cluster model if the requested broker capacity is unavailable.excludeRecentlyRemovedBrokers
- Exclude recently removed brokers from proposal generation for replica transfer.goalConfig
- Goals used for this fix.public GoalsConfig goalsConfig()
Anomaly
public Map<Integer,Long> failedBrokers()
public String anomalyId()
public boolean fix() throws Exception
Anomaly
Exception
public String toString()