调整超时时间

dab3eefc · zengqiao · 2b9a6b28 · dab3eefc
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/KafkaConstant.java ...keji/know/streaming/km/common/constant/KafkaConstant.java +1 -1

未找到文件。
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/KafkaConstant.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/constant/KafkaConstant.java
@@ -33,7 +33,7 @@ public class KafkaConstant {

    public static final Integer DATA_VERSION_ONE = 1;

-    public static final Integer ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS = 3000;
+    public static final Integer ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS = 5000;

    public static final Integer KAFKA_SASL_SCRAM_ITERATIONS = 8192;