org.apache.kafka.streams.state

Interface Stores.InMemoryKeyValueFactory<K,V>

Type Parameters:

K - the type of keys

V - the type of values

Enclosing class:

Stores

public static interface Stores.InMemoryKeyValueFactory<K,V>

The interface used to create in-memory key-value stores.

Method Summary

Methods

Modifier and Type	Method and Description
StateStoreSupplier	build() Return the instance of StateStoreSupplier of new key-value store.
Stores.InMemoryKeyValueFactory<K,V>	disableLogging() Indicates that a changelog should not be created for the key-value store
Stores.InMemoryKeyValueFactory<K,V>	enableLogging(java.util.Map<java.lang.String,java.lang.String> config) Indicates that a changelog should be created for the store.
Stores.InMemoryKeyValueFactory<K,V>	maxEntries(int capacity) Limits the in-memory key-value store to hold a maximum number of entries.

Method Detail

maxEntries

Stores.InMemoryKeyValueFactory<K,V> maxEntries(int capacity)

Limits the in-memory key-value store to hold a maximum number of entries. The default is Integer.MAX_VALUE, which is equivalent to not placing a limit on the number of entries.

Parameters:

capacity - the maximum capacity of the in-memory cache; should be one less than a power of 2

Returns:

this factory

Throws:

java.lang.IllegalArgumentException - if the capacity is not positive

enableLogging

Stores.InMemoryKeyValueFactory<K,V> enableLogging(java.util.Map<java.lang.String,java.lang.String> config)

Indicates that a changelog should be created for the store. The changelog will be created with the provided cleanupPolicy and configs. Note: Any unrecognized configs will be ignored.

Parameters:

config - any configs that should be applied to the changelog

Returns:

the factory to create an in-memory key-value store

disableLogging

Stores.InMemoryKeyValueFactory<K,V> disableLogging()

Indicates that a changelog should not be created for the key-value store

Returns:

the factory to create an in-memory key-value store

build

StateStoreSupplier build()

Return the instance of StateStoreSupplier of new key-value store.

Returns:

the state store supplier; never null