diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java b/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java
index a66cbbd232..5dd7c40ba8 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java
@@ -63,7 +63,7 @@ public class TbKafkaSettings {
     @Value("${queue.kafka.linger.ms}")
     private long lingerMs;
 
-    @Value("${queue.kafka.max.request.size}")
+    @Value("${queue.kafka.max.request.size:1048576}")
     private int maxRequestSize;
 
     @Value("${queue.kafka.max.in.flight.requests.per.connection:5}")