diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java index 5c798b7c3..e6492c974 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java @@ -93,6 +93,16 @@ private static String send4LetterWord( sslSock.connect(hostaddress, timeout); sslSock.startHandshake(); socket = sslSock; + if (sslSock != null) { + try { + sslSock.close(); + } catch (IOException e) { + LOGGER.error( + "method=send4LetterWord||host={}||port={}||cmd={}||secure={}||timeout={}||errMsg=exception!", + host, port, cmd, secure, timeout, e + ); + } + } } } else { socket = new Socket();