Package org.apache.kafka.streams.state

Interface KeyValueBytesStoreSupplier

All Superinterfaces:

StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>

All Known Implementing Classes:

RocksDbKeyValueBytesStoreSupplier

public interface KeyValueBytesStoreSupplier
extends StoreSupplier<KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>>

A store supplier that can be used to create one or more KeyValueStore<Byte, byte[]> instances of type <Byte, byte[]>. For any stores implementing the KeyValueStore<Byte, byte[]> interface, null value bytes are considered as "not exist". This means: 1. Null value bytes in put operations should be treated as delete. 2. If the key does not exist, get operations should return null value bytes.

Method Summary

Methods inherited from interface org.apache.kafka.streams.state.StoreSupplier

get, metricsScope, name