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 instances of type <Byte, byte[]>. For any stores implementing the KeyValueStore 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.