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