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")

  }
}

Reply via email to