From 7db757bc1254272c42dcab6756743d6e756f6037 Mon Sep 17 00:00:00 2001 From: zengqiao Date: Wed, 14 Dec 2022 14:12:32 +0800 Subject: [PATCH] =?UTF-8?q?[Optimize]=E4=BC=98=E5=8C=96Connector=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E6=97=B6=E7=9A=84=E5=85=A5=E5=8F=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1、增加config.action.reload的默认值； 2、增加errors.tolerance的默认值； --- .../entity/connect/config/ConnectConfigInfos.java | 15 ++++++++++++--- .../streaming/km/common/constant/Constant.java | 5 +++++ 2 files changed, 17 insertions(+), 3 deletions(-) diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/connect/config/ConnectConfigInfos.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/connect/config/ConnectConfigInfos.java index bb8b773f..f58adbe0 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/connect/config/ConnectConfigInfos.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/connect/config/ConnectConfigInfos.java @@ -7,8 +7,10 @@ import lombok.NoArgsConstructor; import org.apache.kafka.connect.runtime.rest.entities.ConfigInfo; import org.apache.kafka.connect.runtime.rest.entities.ConfigInfos; -import java.util.ArrayList; -import java.util.List; +import java.util.*; + +import static com.xiaojukeji.know.streaming.km.common.constant.Constant.CONNECTOR_CONFIG_ACTION_RELOAD_NAME; +import static com.xiaojukeji.know.streaming.km.common.constant.Constant.CONNECTOR_CONFIG_ERRORS_TOLERANCE_NAME; /** * @see ConfigInfos @@ -17,6 +19,13 @@ import java.util.List; @NoArgsConstructor @AllArgsConstructor public class ConnectConfigInfos { + + private static final Map> recommendValuesMap = new HashMap<>(); + + static { + recommendValuesMap.put(CONNECTOR_CONFIG_ACTION_RELOAD_NAME, Arrays.asList("none", "restart")); + recommendValuesMap.put(CONNECTOR_CONFIG_ERRORS_TOLERANCE_NAME, Arrays.asList("none", "all")); + } private String name; private int errorCount; @@ -48,7 +57,7 @@ public class ConnectConfigInfos { ConnectConfigValueInfo value = new ConnectConfigValueInfo(); value.setName(configInfo.configValue().name()); value.setValue(configInfo.configValue().value()); - value.setRecommendedValues(configInfo.configValue().recommendedValues()); + value.setRecommendedValues(recommendValuesMap.getOrDefault(configInfo.configValue().name(), configInfo.configValue().recommendedValues())); value.setErrors(configInfo.configValue().errors()); value.setVisible(configInfo.configValue().visible()); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/Constant.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/Constant.java index df7ecce3..c8f4075b 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/Constant.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/Constant.java @@ -65,4 +65,9 @@ public class Constant { public static final Integer DEFAULT_RETRY_TIME = 3; public static final Integer ZK_ALIVE_BUT_4_LETTER_FORBIDDEN = 11; + + public static final String CONNECTOR_CONFIG_ACTION_RELOAD_NAME = "config.action.reload"; + + public static final String CONNECTOR_CONFIG_ERRORS_TOLERANCE_NAME = "errors.tolerance"; + }