Hi Muhammed,
RocksDB is not an in-memory store. If you use only
InMemoryKeyValueStore, you are not using any RocksDB.
Best,
Bruno
On Wed, Jul 17, 2019 at 3:26 PM Muhammed Ashik <ashi...@gmail.com> wrote:
>
> Hi I'm trying to log the rocksdb stats with the below code, but not
> observing any logs..
> I'm enabling this as the off-heap memory grows indefinitely over a
> period of time.
> We were using inMemoryKeyValueStore only, I was not sure kafka-streams uses
> rockdb as default in memory store.
>
> Kafka Streams version - 2.0.0
>
> class CustomRocksDBConfig extends RocksDBConfigSetter {
> override def setConfig(storeName: String, options: Options, configs:
> util.Map[String, AnyRef]): Unit = {
>
> val stats = new Statistics
> stats.setStatsLevel(StatsLevel.ALL)
> options.setStatistics(stats)
> .setStatsDumpPeriodSec(600)
> options
> .setInfoLogLevel(InfoLogLevel.INFO_LEVEL)
> options.setDbLogDir("/tmp/dump")
>
> }
> }
