diff --git a/backend/src/main/java/io/metersphere/config/KafkaProperties.java b/backend/src/main/java/io/metersphere/config/KafkaProperties.java
index c5ce188c15..9406320c54 100644
--- a/backend/src/main/java/io/metersphere/config/KafkaProperties.java
+++ b/backend/src/main/java/io/metersphere/config/KafkaProperties.java
@@ -24,7 +24,7 @@ public class KafkaProperties {
     private String batchSize;
     private String clientId;
     private String connectionsMaxIdleMs;
-    private String queueSize = "5000";
+    private String queueSize = "20000"; // backend listener queue size
     private KafkaProperties.Ssl ssl = new KafkaProperties.Ssl();
     private KafkaProperties.Log log = new KafkaProperties.Log();