kafka settings: added default values for values for TbKafkaSettings class

common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaSettings.java

@@ -53,34 +53,34 @@ public class TbKafkaSettings {
     @Value("${queue.kafka.ssl.enabled:false}")
     private boolean sslEnabled;
 
-    @Value("${queue.kafka.ssl.truststore.location}")
+    @Value("${queue.kafka.ssl.truststore.location:}")
     private String sslTruststoreLocation;
 
-    @Value("${queue.kafka.ssl.truststore.password}")
+    @Value("${queue.kafka.ssl.truststore.password:}")
     private String sslTruststorePassword;
 
-    @Value("${queue.kafka.ssl.keystore.location}")
+    @Value("${queue.kafka.ssl.keystore.location:}")
     private String sslKeystoreLocation;
 
-    @Value("${queue.kafka.ssl.keystore.password}")
+    @Value("${queue.kafka.ssl.keystore.password:}")
     private String sslKeystorePassword;
 
-    @Value("${queue.kafka.ssl.key.password}")
+    @Value("${queue.kafka.ssl.key.password:}")
     private String sslKeyPassword;
 
-    @Value("${queue.kafka.acks}")
+    @Value("${queue.kafka.acks:all}")
     private String acks;
 
-    @Value("${queue.kafka.retries}")
+    @Value("${queue.kafka.retries:1}")
     private int retries;
 
     @Value("${queue.kafka.compression.type:none}")
     private String compressionType;
 
-    @Value("${queue.kafka.batch.size}")
+    @Value("${queue.kafka.batch.size:16384}")
     private int batchSize;
 
-    @Value("${queue.kafka.linger.ms}")
+    @Value("${queue.kafka.linger.ms:1}")
     private long lingerMs;
 
     @Value("${queue.kafka.max.request.size:1048576}")
@@ -89,10 +89,10 @@ public class TbKafkaSettings {
     @Value("${queue.kafka.max.in.flight.requests.per.connection:5}")
     private int maxInFlightRequestsPerConnection;
 
-    @Value("${queue.kafka.buffer.memory}")
+    @Value("${queue.kafka.buffer.memory:33554432}")
     private long bufferMemory;
 
-    @Value("${queue.kafka.replication_factor}")
+    @Value("${queue.kafka.replication_factor:1}")
     @Getter
     private short replicationFactor;
 
@@ -111,16 +111,16 @@ public class TbKafkaSettings {
     @Value("${queue.kafka.use_confluent_cloud:false}")
     private boolean useConfluent;
 
-    @Value("${queue.kafka.confluent.ssl.algorithm}")
+    @Value("${queue.kafka.confluent.ssl.algorithm:}")
     private String sslAlgorithm;
 
-    @Value("${queue.kafka.confluent.sasl.mechanism}")
+    @Value("${queue.kafka.confluent.sasl.mechanism:}")
     private String saslMechanism;
 
-    @Value("${queue.kafka.confluent.sasl.config}")
+    @Value("${queue.kafka.confluent.sasl.config:}")
     private String saslConfig;
 
-    @Value("${queue.kafka.confluent.security.protocol}")
+    @Value("${queue.kafka.confluent.security.protocol:}")
     private String securityProtocol;
 
     @Setter