org.apache.kafka.streams.state

Interface RocksDBConfigSetter

public interface RocksDBConfigSetter

An interface to that allows developers to customize the RocksDB settings for a given Store. Please read the RocksDB Tuning Guide. Note: if you choose to modify the org.rocksdb.BlockBasedTableConfig you should retrieve a reference to the existing one (rather than create a new BlockBasedTableConfig object) so as to not lose the other default settings. This can be done as BlockBasedTableConfig tableConfig = (BlockBasedTableConfig) options.tableFormatConfig();

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
default void	close(String storeName, org.rocksdb.Options options) Close any user-constructed objects that inherit from org.rocksdb.RocksObject.
void	setConfig(String storeName, org.rocksdb.Options options, Map<String,Object> configs) Set the rocks db options for the provided storeName.

Field Detail

LOG

static final org.slf4j.Logger LOG

Method Detail

setConfig

void setConfig(String storeName,
               org.rocksdb.Options options,
               Map<String,Object> configs)

Set the rocks db options for the provided storeName.

Parameters:

storeName - the name of the store being configured

options - the RocksDB options

configs - the configuration supplied to StreamsConfig

close

default void close(String storeName,
                   org.rocksdb.Options options)

Close any user-constructed objects that inherit from org.rocksdb.RocksObject.

Any object created with new in setConfig() and that inherits from org.rocksdb.RocksObject should have org.rocksdb.RocksObject#close() called on it here to avoid leaking off-heap memory. Objects to be closed can be saved by the user or retrieved back from options using its getter methods.

Example objects needing to be closed include org.rocksdb.Filter and org.rocksdb.Cache.

Parameters:

storeName - the name of the store being configured

options - the RocksDB options