Package 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 Description
    static org.slf4j.Logger LOG  

  • Method Summary

    Modifier and Type Method Description
    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 Details

    • LOG

      static final org.slf4j.Logger LOG

  • Method Details

    • 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

      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