diff --git a/backend/src/main/java/io/metersphere/parse/xml/reader/jmx/JmeterDocumentParser.java b/backend/src/main/java/io/metersphere/parse/xml/reader/jmx/JmeterDocumentParser.java index 4575d34f5e..2f44539943 100644 --- a/backend/src/main/java/io/metersphere/parse/xml/reader/jmx/JmeterDocumentParser.java +++ b/backend/src/main/java/io/metersphere/parse/xml/reader/jmx/JmeterDocumentParser.java @@ -106,6 +106,7 @@ public class JmeterDocumentParser implements DocumentParser { // 清空child removeChildren(backendListener); backendListener.appendChild(createStringProp(document, "classname", "io.github.rahulsinghai.jmeter.backendlistener.kafka.KafkaBackendClient")); + backendListener.appendChild(createStringProp(document, "QUEUE_SIZE", "5000")); // elementProp Element elementProp = document.createElement("elementProp"); elementProp.setAttribute("name", "arguments"); diff --git a/backend/src/test/java/io/metersphere/JmxFileParseTest.java b/backend/src/test/java/io/metersphere/JmxFileParseTest.java index b7ff2fb536..31ec87cf55 100644 --- a/backend/src/test/java/io/metersphere/JmxFileParseTest.java +++ b/backend/src/test/java/io/metersphere/JmxFileParseTest.java @@ -118,6 +118,7 @@ public class JmxFileParseTest { // 清空child removeChildren(backendListener); backendListener.appendChild(createStringProp(document, "classname", "io.github.rahulsinghai.jmeter.backendlistener.kafka.KafkaBackendClient")); + backendListener.appendChild(createStringProp(document, "QUEUE_SIZE", "5000")); // elementProp Element elementProp = document.createElement("elementProp"); elementProp.setAttribute("name", "arguments");