org.apache.kafka.streams.processor

Interface StateStoreSupplier<T extends StateStore>

Type Parameters:

T - State store type

public interface StateStoreSupplier<T extends StateStore>

A state store supplier which can create one or more StateStore instances.

Method Summary

Methods

Modifier and Type	Method and Description
T	get() Return a new StateStore instance.
java.util.Map<java.lang.String,java.lang.String>	logConfig() Returns a Map containing any log configs that will be used when creating the changelog for the StateStore
boolean	loggingEnabled()
java.lang.String	name() Return the name of this state store supplier.

Method Detail

name

java.lang.String name()

Return the name of this state store supplier. This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-'

Returns:

the name of this state store supplier

get

T get()

Return a new StateStore instance.

Returns:

a new StateStore instance of type T

logConfig

java.util.Map<java.lang.String,java.lang.String> logConfig()

Returns a Map containing any log configs that will be used when creating the changelog for the StateStore

Note: any unrecognized configs will be ignored by the Kafka brokers.

Returns:

Map containing any log configs to be used when creating the changelog for the StateStore If loggingEnabled returns false, this function will always return an empty map

loggingEnabled

boolean loggingEnabled()

Returns:

true if the StateStore should have logging enabled