refactor(性能测试): 性能测试启动增加一个ENV, topic

backend/src/main/java/io/metersphere/config/KafkaProperties.java

@@ -27,6 +27,7 @@ public class KafkaProperties {
     private String queueSize = "20000"; // backend listener queue size
     private KafkaProperties.Ssl ssl = new KafkaProperties.Ssl();
     private KafkaProperties.Log log = new KafkaProperties.Log();
+    private KafkaProperties.Report report = new KafkaProperties.Report();
 
     @Getter
     @Setter
@@ -49,4 +50,10 @@ public class KafkaProperties {
     public static class Log {
         private String topic;
     }
+
+    @Getter
+    @Setter
+    public static class Report {
+        private String topic;
+    }
 }

backend/src/main/java/io/metersphere/performance/engine/docker/DockerTestEngine.java

@@ -90,6 +90,7 @@ public class DockerTestEngine extends AbstractEngine {
         env.put("REPORT_ID", this.getReportId());
         env.put("BOOTSTRAP_SERVERS", kafkaProperties.getBootstrapServers());
         env.put("LOG_TOPIC", kafkaProperties.getLog().getTopic());
+        env.put("JMETER_REPORTS_TOPIC", kafkaProperties.getReport().getTopic());
         env.put("RESOURCE_ID", resource.getId());
         env.put("THREAD_NUM", "0");// 传入0表示不用修改线程数
         env.put("HEAP", HEAP);