Modifier and Type | Field and Description |
---|---|
protected OptimizationResult |
optimizationResult |
Constructor and Description |
---|
BrokerFailures(KafkaCruiseControl kafkaCruiseControl,
Map<Integer,Long> failedBrokers,
boolean allowCapacityEstimation,
boolean excludeRecentlyDemotedBrokers,
boolean excludeRecentlyRemovedBrokers,
List<String> selfHealingGoals)
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.
|
String |
toString() |
protected OptimizationResult optimizationResult
public BrokerFailures(KafkaCruiseControl kafkaCruiseControl, Map<Integer,Long> failedBrokers, boolean allowCapacityEstimation, boolean excludeRecentlyDemotedBrokers, boolean excludeRecentlyRemovedBrokers, List<String> selfHealingGoals)
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.excludeRecentlyDemotedBrokers
- Exclude recently demoted brokers from proposal generation for leadership transfer.excludeRecentlyRemovedBrokers
- Exclude recently removed brokers from proposal generation for replica transfer.selfHealingGoals
- Goals used for self healing. An empty list indicates the default goals.public Map<Integer,Long> failedBrokers()
public String anomalyId()
public boolean fix() throws Exception
Anomaly
Exception
public String toString()