diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java index d75dec5a..fed4ccda 100644 --- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java +++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java @@ -89,15 +89,15 @@ public class DidiHealthScoreStrategy extends AbstractHealthScoreStrategy { return HEALTH_SCORE_BAD; } - Object RequestHandlerAvgIdlePercentOneMinuteRate = metrics.getMetricsMap().get("RequestHandlerAvgIdlePercentOneMinuteRate"); - Object NetworkProcessorAvgIdlePercentValue = metrics.getMetricsMap().get("NetworkProcessorAvgIdlePercentValue"); - if (ValidateUtils.isNull(RequestHandlerAvgIdlePercentOneMinuteRate) - || ValidateUtils.isNull(NetworkProcessorAvgIdlePercentValue)) { + Object requestHandlerAvgIdlePercentOneMinuteRate = metrics.getMetricsMap().get("RequestHandlerAvgIdlePercentOneMinuteRate"); + Object networkProcessorAvgIdlePercentValue = metrics.getMetricsMap().get("NetworkProcessorAvgIdlePercentValue"); + if (ValidateUtils.isNull(requestHandlerAvgIdlePercentOneMinuteRate) + || ValidateUtils.isNull(networkProcessorAvgIdlePercentValue)) { // 数据获取失败 return Constant.INVALID_CODE; } - if (((Double) RequestHandlerAvgIdlePercentOneMinuteRate) < MIN_IDLE * KAFKA_REQUEST_HANDLER_POOL_SIZE - || ((Double) NetworkProcessorAvgIdlePercentValue) < MIN_IDLE) { + if (((Double) requestHandlerAvgIdlePercentOneMinuteRate) < MIN_IDLE * KAFKA_REQUEST_HANDLER_POOL_SIZE + || ((Double) networkProcessorAvgIdlePercentValue) < MIN_IDLE) { return HEALTH_SCORE_NORMAL; } return HEALTH_SCORE_HEALTHY;