RocksdbCfg implements ConfigurationEntry { public Properties getColumnFamilyOptions() { return columnFamilyOptions; }  @Override void init(final BrokerCfg globalConfig, final String brokerBase); Properties getColumnFamilyOptions(); void setColumnFamilyOptions(final Properties columnFamilyOptions);  }
@Test public void shouldSetColumnFamilyOptionsConfig() { final BrokerCfg cfg = TestConfigReader.readConfig("rocksdb-cfg", environment); final var rocksdb = cfg.getData().getRocksdb(); final var columnFamilyOptions = rocksdb.getColumnFamilyOptions(); assertThat(columnFamilyOptions).containsEntry("compaction_pri", "kOldestSmallestSeqFirst"); assertThat(columnFamilyOptions).containsEntry("write_buffer_size", "67108864"); }
@Test public void shouldSetColumnFamilyOptionsConfigFromEnvironmentVariables() { environment.put("zeebe.broker.data.rocksdb.columnFamilyOptions.arena.block.size", "16777216"); final BrokerCfg cfg = TestConfigReader.readConfig("rocksdb-cfg", environment); final var rocksdb = cfg.getData().getRocksdb(); final var columnFamilyOptions = rocksdb.getColumnFamilyOptions(); assertThat(columnFamilyOptions).containsEntry("arena_block_size", "16777216"); }