dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Avoid start of RocksDb in Kafka mode

Browse Source
This commit is contained in:
Andrii Shvaika 2025-02-27 18:17:03 +02:00
parent 62da129d6b
commit 5ca236f8fe
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
application/src/main/java/org/thingsboard/server/service/cf/CfRocksDb.java
View File

@ -19,10 +19,12 @@ import jakarta.annotation.PreDestroy;
import org.rocksdb.Options; import org.rocksdb.Options;
import org.rocksdb.WriteOptions; import org.rocksdb.WriteOptions;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.thingsboard.server.utils.TbRocksDb; import org.thingsboard.server.utils.TbRocksDb;
@Component @Component
@ConditionalOnExpression("'${queue.type:null}'=='in-memory'")
public class CfRocksDb extends TbRocksDb { public class CfRocksDb extends TbRocksDb {
public CfRocksDb(@Value("${queue.calculated_fields.rocks_db_path:${user.home}/.rocksdb/cf_states}") String path) throws Exception { public CfRocksDb(@Value("${queue.calculated_fields.rocks_db_path:${user.home}/.rocksdb/cf_states}") String path) throws Exception {