From 1d7e0b9851d014fc355e038977f9b81299b71798 Mon Sep 17 00:00:00 2001 From: Sergey Matvienko Date: Tue, 13 Jul 2021 10:50:32 +0300 Subject: [PATCH] queue.kafka.max.request.size:1048576 default to tolerate inconsistent or outdated yml --- .../org/thingsboard/server/queue/kafka/TbKafkaSettings.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}")