chore(性能测试): 修复检查kafka的时候导致的kafka日志异常

backend/src/main/java/io/metersphere/performance/service/PerformanceTestService.java

@@ -45,7 +45,6 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.annotation.Resource;
 import java.io.File;
 import java.io.IOException;
-import java.io.OutputStream;
 import java.net.InetSocketAddress;
 import java.net.Socket;
 import java.nio.charset.StandardCharsets;
@@ -318,15 +317,11 @@ public class PerformanceTestService {
                 //1,建立tcp
                 String ip = ipAndPort[0];
                 int port = Integer.parseInt(ipAndPort[1]);
-                Socket soc = new Socket();
-                soc.connect(new InetSocketAddress(ip, port), 1000); // 1s timeout
-                //2.输入内容
-                String content = "1010";
-                byte[] bs = content.getBytes();
-                OutputStream os = soc.getOutputStream();
-                os.write(bs);
-                //3.关闭
-                soc.close();
+                try (
+                        Socket soc = new Socket();
+                ) {
+                    soc.connect(new InetSocketAddress(ip, port), 1000); // 1s timeout
+                }
             }
         } catch (Exception e) {
             LogUtil.error(e.getMessage(), e);