org.apache.kafka.streams.state

Interface Stores.KeyValueFactory<K,V>

Enclosing class:

Stores

public static interface Stores.KeyValueFactory<K,V>

Method Summary

Modifier and Type	Method and Description
Stores.InMemoryKeyValueFactory<K,V>	inMemory() Keep all key-value entries in-memory, although for durability all entries are recorded in a Kafka topic that can be read to restore the entries if they are lost.
Stores.PersistentKeyValueFactory<K,V>	persistent() Keep all key-value entries off-heap in a local database, although for durability all entries are recorded in a Kafka topic that can be read to restore the entries if they are lost.

Method Detail

inMemory

Stores.InMemoryKeyValueFactory<K,V> inMemory()

Keep all key-value entries in-memory, although for durability all entries are recorded in a Kafka topic that can be read to restore the entries if they are lost.

Returns:

the factory to create in-memory key-value stores; never null

persistent

Stores.PersistentKeyValueFactory<K,V> persistent()

Keep all key-value entries off-heap in a local database, although for durability all entries are recorded in a Kafka topic that can be read to restore the entries if they are lost.

Returns:

the factory to create persistent key-value stores; never null