kafka-streams-internals-RocksDbKeyValueBytesStoreSupplier.adoc

RocksDbKeyValueBytesStoreSupplier

RocksDbKeyValueBytesStoreSupplier is a KeyValueBytesStoreSupplier.

RocksDbKeyValueBytesStoreSupplier is created when Stores utility is used to create persistent KeyValueStores:

• Stores.persistentKeyValueStore (with the returnTimestampedStore off)

• Stores.persistentTimestampedKeyValueStore (with the returnTimestampedStore on)

RocksDbKeyValueBytesStoreSupplier uses rocksdb-state metric scope for the metrics recorded by Metered stores.

Creating RocksDbKeyValueBytesStoreSupplier Instance

RocksDbKeyValueBytesStoreSupplier takes the following to be created:

• Name

• returnTimestampedStore flag

Supplying KeyValueStore — get Method

KeyValueStore<Bytes, byte[]> get()

Note	get is part of the StoreSupplier Contract to supply (get) a state store.

get gives the following KeyValueStores:

• RocksDBTimestampedStore when returnTimestampedStore is on (true)

• RocksDBStore when returnTimestampedStore is off (false)