From 5ca236f8fe281d90442667fd74fecf64e58d4d0f Mon Sep 17 00:00:00 2001 From: Andrii Shvaika Date: Thu, 27 Feb 2025 18:17:03 +0200 Subject: [PATCH] Avoid start of RocksDb in Kafka mode --- .../main/java/org/thingsboard/server/service/cf/CfRocksDb.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/application/src/main/java/org/thingsboard/server/service/cf/CfRocksDb.java b/application/src/main/java/org/thingsboard/server/service/cf/CfRocksDb.java index 90c796f1f8..cb6d3f0d6b 100644 --- a/application/src/main/java/org/thingsboard/server/service/cf/CfRocksDb.java +++ b/application/src/main/java/org/thingsboard/server/service/cf/CfRocksDb.java @@ -19,10 +19,12 @@ import jakarta.annotation.PreDestroy; import org.rocksdb.Options; import org.rocksdb.WriteOptions; import org.springframework.beans.factory.annotation.Value; +import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; import org.springframework.stereotype.Component; import org.thingsboard.server.utils.TbRocksDb; @Component +@ConditionalOnExpression("'${queue.type:null}'=='in-memory'") public class CfRocksDb extends TbRocksDb { public CfRocksDb(@Value("${queue.calculated_fields.rocks_db_path:${user.home}/.rocksdb/cf_states}") String path) throws Exception {