queue.kafka.max.request.size:1048576 default to tolerate inconsistent or outdated yml

5 years ago · 1d7e0b9851
1 changed files with 1 additions and 1 deletions
--- 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}")