public interface StateStoreSupplier
StateStore
instances.Modifier and Type | Method and Description |
---|---|
StateStore |
get()
Return a new
StateStore instance. |
Map<String,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. |
boolean |
loggingEnabled() |
String |
name()
Return the name of this state store supplier.
|
String name()
StateStore get()
StateStore
instance.StateStore
instanceMap<String,String> logConfig()
StateStore
Note: any unrecognized configs will be ignored by the Kafka brokers.StateStore
If loggingEnabled
returns false, this function will always return an empty mapboolean loggingEnabled()
StateStore
should have logging enabled